kafka 输入(2.12)
id: kafka_2.12
参数:
servers[必选]:用于建立与Kafka集群的初始连接的列表主机/端口
topics[必选]:kafka消费的topic, 多个逗号分隔
group_id[必选]:消费组id
consume_timeout[必选]:消费间隔时间, 单位: 毫秒
threads[必选] 采集的线程数量,建议一个Kafka topic,一个线程
fetch_min_bytes[必选]: 采集最小字节数, 当一批日志消息的数量达到此字节数,或超过设定的等待时间,即开始采集
fetch_max_wait_ms[必选]:采集等待时间, 超过此等待时间,或消息累积达到设定的字节数,即开始采集。单位:ms
ssl_allowed[必选]:ssl通信, 是否允许与kafka代理进行ssl通信, 如果启用,与代理的通信将在SSL中完成。请检查kafka代理配置ssl端口。 可选值:true、false
ssl_truststore_location[可选]:信任存储证书文件的路径[ssl_allowed:true 可用]
ssl_truststore_password[可选]:访问信任存储的密码[ssl_allowed:true 可用]
http 输入
id: http
tcp 输入
id: tcp
udp 输入
id: udp