# write-kafka

Connect to brokers and produce messages to topic. Messages are buffered until either buffer or interval seconds has been reached.

Required:

• brokers (string[]): Array of Kafka broker address:port
• topic (string): Topic to produce to

Optional:

• client (string): Kafka client ID (default: logbus)
• buffer (number): Events to buffer before shipping (default: 1000)
• interval (number): Interval in seconds between shipments (default: 60)

pipeline:
  write-kafka:
    config:
      brokers:
        - kafka1:9092
        - kafka2:9092
      topic: logs
      client: logbus-instance-1