使用相同的logstash文件发送不同的输出

Question

我需要我的logstash conf文件向一个kafka主题发送一条消息，以指示已处理的文档已发送到ElasticSearch。我已经准备好了logstash文件来构造发送到ElasticSearch的数据，但是我需要通过同一个logstash文件向kafka主题发布“是”或“否”消息。

Answer 1

您可以使用多种输出，如

output 
    { 
        #output to console
        stdout { 
            codec => rubydebug 
               } 

        #output to elasticsearch    
        elasticsearch {
            hosts => [ "192.168.1.245:9201" ]
                      }

        #output to kafka          
        kafka {
            codec => json
            topic_id => "mytopic"
              }   

    }