我试着和Kafka经纪人用logstash。它不能集成在一起。
每个版本都是，
日志2.4
Kafka0.8.2.2和scala 2.10
kafka输入配置文件是：

input { 
  stdin{
  }      
}
output{
  stdout {
    codec => rubydebug
  }

  kafka {
    bootstrap_servers => 10.120.16.202:6667,10.120.16.203:6667,10.120.16.204:6667'
    topic_id => "cephosd1"
  }
}

我可以列出Kafka的主题cephosd1。标准输出也可以打印出内容。
但我看不懂kafka-console-consumer.sh中的任何内容。