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


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.