Skip to main content

Kafka

Produces messages to a Kafka topic.

FieldTypeDefaultDescription
Addressesarray—Kafka broker addresses
Topicstring—Target topic
Keystring—Message key (Bloblang interpolation)
CompressionstringnoneCompression: none, gzip, snappy, lz4, zstd
Max In Flightinteger64Maximum parallel produces
Batchingobject—Batching policy

Supports SASL authentication and TLS.