Logstash 5 不输出 filebeat 输入和 Kafka 输入

Question

下面是 Logstash 5 服务器上的配置

input {
kafka {
topics => ["logstash_logs"]
bootstrap_servers => "zk_server:2181"
codec => plain {
format => "%{message}"
}
}
}
input {
beats {
port => 5044
ssl => true
ssl_certificate => "/etc/pki/tls/certs/logstash-forwarder.crt"
ssl_key => "/etc/pki/tls/private/logstash-forwarder.key"
}
}
output{
stdout{}
}

文件节拍与 Logstash 服务器配置在同一台机器上。它也配置正确。

我仍然看不到/var/log/logstash/logstash.stdout 中的数据。

logstash 以 -log.level=debug 开头，但我在 log/var/log/logstash/logstash 中看不到任何东西.log

请帮我调试设置

Answer 1

>bootstrap_servers指的是Kafka代理本身，而不是Zookeeper实例。从 Kafka 0.9 开始，消费者不再直接与 Zookeeper 打交道（除非它真的想这样做）。

这里真正的问题是 Logstash 没有为用户提供足够的信息来推断为什么这不起作用。此外，文档也没有明确说明这是Kafka而不是Zookeeper。但是，它们确实在默认端口号中提供了提示 :9092 。

见 https://www.elastic.co/guide/en/logstash/5.0/plugins-inputs-kafka.html#plugins-inputs-kafka-bootstrap_servers

Answer 2

将端口号从 2181 更改为 9092 ，有同样的问题。检查日志，在日志存储日志上执行尾部操作tail -f -10 /var/log/logstash/logstash.log您应该看到ipaddress:2181连接被拒绝。