具有多个kafka输入的Logstash

这是一个非常晚的回复，但如果你想输入多个主题和输出到另一个kafka多输出，你可以做这样的事情：

    
          input {
  enter code herekafka {
    topics => [“topic1”, “topic2”]
    codec => “json”
    bootstrap_servers => “kafka-broker-1:9092,kafka-broker-2:9092,kafka-broker-3:9092”
    decorate_events => true
    group_id => “logstash-multi-topic-consumers”
    consumer_threads => 5
  }
}
output {
   if [kafka][topic] == “topic1” {
     kafka {
       codec => “json”
       topic_id => “new_topic1”
       bootstrap_servers => “output-kafka-1:9092”
     }
   }
   else if [kafka][topic] == “topic2” {
      kafka {
       codec => “json”
       topic_id => “new_topic2”
       bootstrap_servers => “output-kafka-1:9092”
      }
    }
}
</code>