Kafka+Logstash的问题

本人采用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
有没有大神用过这种架构指点一下