kafka 输入(2.12)

id: kafka_2.12参数:

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

http 输入

id: http

tcp 输入

id: tcp

udp 输入

id: udp