Skip to main content

Kafka

Consumes messages from one or more Kafka topics.

FieldTypeDefaultDescription
AddressesarrayKafka broker addresses
TopicsarrayTopics to consume
Consumer GroupstringConsumer group ID
Checkpoint Limitinteger1024Max unprocessed messages before committing
Auto Replay NacksbooleantrueAutomatically replay rejected messages

Supports SASL authentication (PLAIN, SCRAM-SHA-256, SCRAM-SHA-512) and TLS.