Logstash 5不输出filebeat输入和卡夫卡输入

Question

下面是

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{} 
} 

filebeat是同一台机器上配置为Logstash服务器的Logstash 5服务器上的配置。它的配置也是正确的。

我仍然无法在/var/log/logstash/logstash.stdout中看到数据。

logstash开始与-log.level =调试我仍然无法看到任何东西日志/var/log/logstash/logstash.log

请帮我调试安装

Answer 1

bootstrap_servers指卡夫卡经纪人本身，而不是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的端口号，有同样的问题。 检查日志，在logstash日志上做一个尾部tail -f -10 /var/log/logstash/logstash.log你应该看到ipaddress:2181连接被拒绝。