1.kafka输入插件 input { kafka { bootstrap_servers => "test1:9092,test2:9092,test3:9092" #集群地址 topics => ["test"] #主题，可以有多...

1.kafka输入插件 input { kafka { bootstrap_servers => "test1:9092,test2:9092,test3:9092" #集群地址 topics => ["test"] #主题，可以有多...