Kafka

A sink that implements a Kafka producer. Each event is json-encoded and sent as a message to a single Kafka topic.

Configuration

[sink]
type = "Kafka"
brokers = ["kafka-broker-0:9092"]
topic = "cardano-events"

• type: the literal value Kafka.
• brokers: indicates the location of the Kafka brokers within the network. Several hostname:port pairs can be added to the array for a “cluster” scenario.
• topic this field indicates which Kafka topic to use to send the outbound messages.