# write-kafka

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

## Config

**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)

## Example

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