KafkaV3

Kafka is an open source distributed streaming platform.

Category

Messaging and Conferencing

Pack

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
• incidentFetchInterval — Incidents Fetch Interval
• 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.