KafkaV3

Kafka is an open source distributed streaming platform.

Messaging and Conferencing · Kafka

Configuration parameters

  • brokers — CSV list of Kafka brokers to connect to, e.g., 172.16.20.207:9092,172.16.20.234:9093 (required)
  • group_id — Consumer group ID
  • use_ssl — Use TLS for connection
  • use_sasl — Use SASL PLAIN for connection (using SSL)
  • insecure — Trust any certificate (not secure)
  • ca_cert — CA certificate of Kafka server (.cer)
  • client_cert — Client certificate (.cer)
  • client_cert_key — Client certificate key (.key)
  • additional_password —
  • credentials — SASL PLAIN Username
  • topic — Topic to fetch incidents from (Required for fetch incidents)
  • partition — CSV list of partitions to fetch messages from
  • first_fetch — Offset to fetch messages from (Exclusive)
  • max_fetch — Maximum number of messages to fetch
  • stop_consuming_upon_timeout — Stop consuming upon timeout
  • isFetch — Fetch incidents
  • incidentType — Incident type
  • max_bytes_per_message — Maximum number of bytes per message
  • schema_registry_url — Schema Registry URL
  • schema_registry_credentials — Schema Registry Username

Commands (4)

  • kafka-consume-msg

    Consumes a single Kafka message.

  • kafka-fetch-partitions

    Fetch partitions for a topic.

  • kafka-print-topics

    Prints all topics and their partitions.

  • kafka-publish-msg

    Publishes a message to Kafka.