0
計劃將我的ELK設置升級到5.x,同時我嘗試在forwarder和logstash服務器之間在新環境中添加kafka消息隊列。Logstash-5.X Kafka輸入插件:沒有消息從kafka主題讀取
轉發給kafka的郵件沒有問題。我通過kafka消費者腳本來驗證它。
但是當我使用logstash-kafka輸入插件從kafka中提取消息時,它不寫任何消息。我需要在我的配置中添加/啓用任何特定設置嗎?
我logstash簡單的配置:
input {
kafka{
topics => ["weblogs"]
bootstrap_servers => "10.11.12.202:9092"
}
}
output {
stdout { codec => rubydebug }
file {
path => "/tmp/stdout.log"
}
}
的話題卡夫卡消費者腳本輸出:
[[email protected] kafka_2.11-0.10.2.0]# bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic weblogs
10.11.12.169 - - [27/Apr/2017:13:50:26 +0000] "GET/HTTP/1.0" 302 287 "-" "check_http/v2.0.3 (nagios-plugins 2.0.3)"
192.168.10.11 - - [27/Apr/2017:13:50:29 +0000] "GET/HTTP/1.0" 302 281 "-" "check_http/v2.0.3 (nagios-plugins 2.0.3)"
10.11.12.169 - - [27/Apr/2017:13:50:29 +0000] "GET/HTTP/1.0" 302 291 "-" "check_http/v2.0.3 (nagios-plugins 2.0.3)"
10.11.12.169 - - [27/Apr/2017:13:50:32 +0000] "GET/HTTP/1.0" 302 289 "-" "check_http/v2.0.3 (nagios-plugins 2.0.3)"
你在logstash的日誌中看到了什麼? – berrytchaks
除logstash啓動事件消息外,沒有日誌消息。任何想法請 – KMG
請在debug中啓動logstash(/ usr/share/logstash#bin/logstash -f path/to/logstash.conf --log.level debug)模式並共享日誌。 – berrytchaks