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が参照するデバッグのセットアップに私を助けてくださいカフカブローカーそのものではなく、動物園のインスタンスである。 Kafka 0.9から、消費者は（本当に望んでいる場合を除いて）もう動物園管理者に直接対処しません。

ここで実際に問題になるのは、Logstashが、これがなぜ機能していないのかを推定するのに十分な情報を提供していないことです。また、ドキュメンテーションは、これがKookaであり、Zookeeperではないことを明確にしていません。ただし、デフォルトポート番号:9092のヒントを提供します。

は同じ問題を抱えていた、9092にhttps://www.elastic.co/guide/en/logstash/5.0/plugins-inputs-kafka.html#plugins-inputs-kafka-bootstrap_servers

Answer 2

変更2181からポート番号を参照してください。 ログを確認し、ログスタッシュログの末尾にtail -f -10 /var/log/logstash/logstash.logを入力してください。ipaddress:2181接続が拒否されているはずです。