愚者求师之过,智者从师之长。

Kafka+Logstash的问题

Logstash | 作者 dennishood | 发布于2016年11月07日 | 阅读数:6848

本人采用Filebeat5.0+Kafka0.10.1.0+ELK的日志系统架构。在kafka服务器用
 bin/kafka-console-consumer.sh --bootstrap-server 192.168.138.5:9092 --topic filebeat --from-beginning
可以收到消息。
在ELK端收不到消息,以下是logstash的input配置:
input {
  kafka {
    zk_connect => "192.168.138.5:2181"
    group_id => "logstash"
    topic_id => "filebeat"
    codec => "plain"
    reset_beginning => true # boolean (optional), default: false
    consumer_threads => 1  # number (optional), default: 1
    decorate_events => true # boolean (optional), default: false
  }
}
logstash版本2.2.4
有没有大神用过这种架构指点一下
 
已邀请:

dennishood

赞同来自:

OK了本人已解决,还是看官网管用,是kafka和logstash以及input插件的版本对应问题。

要回复问题请先登录注册