LogStash卡夫卡输出/输入不起作用
LogStash卡夫卡输出/输入不起作用
提问于 2016-10-09 16:21:31
我试着和卡夫卡经纪人一起用日志。它不能集成在一起。
每个版本都是，
- logstash 2.4
- kafka 0.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"
}
}我可以列出来自卡夫卡的主题cephosd1。标准输出也可以打印出内容。
但是我看不懂卡夫卡的任何东西--控制台
Stack Overflow用户
发布于 2016-10-10 04:44:23
我觉得你有兼容性问题。如果您检查Logstash、Kafka和kafka输出插件之间的kafka，您将看到Logstash2.4中的kafka输出插件使用了Kafka0.9客户端版本。
如果您有一个Kafka broker 0.8.2.2，那么它与客户端版本0.9不兼容(反过来也可以)。您可以降级到Logstash2.0，或者将您的Kafka代理升级到0.9。
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/39945797
复制相关文章
相似问题
腾讯云开发者
