我正试图用https://www.elastic.co/guide/en/logstash/current/plugins-inputs-kafka.html
我已经运行了kafka和zookeeper（我已经用python创建了生产者和消费者来验证这一点），但是logstash不会检测到kafka，
我已经安装了kafka输入插件，我的conf文件是这样的：
input {
kafka {
bootstrap_servers => "localhost:9092"
topics => ["divolte-data"]
}
}
output {
elasticsearch {
hosts => ["localhost:9200"]
index => "divolte-data"
}
}任何帮助都将不胜感激。
1条答案
按热度按时间toe950271#
我想问题出在版本上。既然你在跑步
ES 2.3，不兼容使用bootstrap_servers在kafka输入插件中，它是从5.0版本引入的。根据文档，您应该使用zk\u connect而不是
bootstrap_servers，如下所示：