Kafka
简介
flusher_kafka flusher插件可以实现将采集到的数据，经过处理后，发送到Kafka。
版本
Deprecated，请使用flusher_kafka_v2
配置参数
| 参数 | 类型 | 是否必选 | 说明 |
|---|---|---|---|
| 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: input_file
FilePaths:
- /home/test-log/*.log
flushers:
- Type: flusher_kafka
Brokers:
- 192.XX.XX.1:9092
- 192.XX.XX.2:9092
Topic: KafkaTestTopic