Kafka

简介

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