Skip to main content

Kafka

Produces messages to a Kafka topic.

FieldTypeDefaultDescription
AddressesarrayKafka broker addresses
TopicstringTarget topic
KeystringMessage key (Bloblang interpolation)
CompressionstringnoneCompression: none, gzip, snappy, lz4, zstd
Max In Flightinteger64Maximum parallel produces
BatchingobjectBatching policy

Supports SASL authentication and TLS.