flusher_kafka flusher插件可以实现将采集到的数据，经过处理后，发送到Kafka。
| 参数 | 类型 | 是否必选 | 说明 |
|---|---|---|---|
| Type | String | 是 | 插件类型 |
| Brokers | String数组 | 是 | Kafka Brokers |
| Topic | String | 是 | Kafka Topic |
| SASLUsername | String | 否 | SASL用户名 |
| SASLPassword | String | 否 | SASL密码 |
| PartitionerType | String | 否 | Partitioner类型。取值：roundrobin、hash、random。默认为：random。 |
| HashKeys | String数组 | 否 | PartitionerType为hash时，需指定HashKeys。 |
| HashOnce | Boolean | 否 | |
| ClientID | String | 否 | 写入Kafka的Client ID，默认取值：LogtailPlugin。 |
采集/home/test-log/路径下的所有文件名匹配*.log规则的文件，并将采集结果发送到Kafka。
enable: true
inputs:
- Type: file_log
LogPath: /home/test_log
FilePattern: "*.log"
flushers:
- Type: flusher_kafka
Brokers:
- 192.XX.XX.1:9092
- 192.XX.XX.2:9092
Topic: KafkaTestTopic