logstash-input-kafka_logstash input kafka

作者：2023面试高手 | 2024-05-16 20:53:17

踩

logstash input kafka

kafka.conf:

input{


input{
  kafka{
    bootstrap_servers =>["10.121.69.2:9092","数组，可以写多个"]
    group_id => "test_consumer_grup"
    auto_offset_reset => "latest"
    consumer_threads => 5
    decorate_events => true
    topics => ["kafka_logstash","数组，可以写多个"]
    type => "zhang"
  }
}
output {
  elasticsearch {
    hosts => ["10.121.69.1:9200","数组，可以写多个"]
    index => "logstash-%{[可以是字段里面的名字]}-%{+YYYY.MM.dd}"
  }
}

}

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/2023面试高手/article/detail/580417