Enable to connect Logstash to Kafka

(Youssef El) #1


I'm trying to connect Kafka to logastash by making kafka input in logstash config file ,but i'm confused with kafka bootstrap_servers who is hosted in hortonworks platform .

In ambari UI is mentioned that kafka listen on port 6667 but in Elastic documentation is mentioned port number 9092.


(Canh.Bui) #2

Hello, this is my config
input {
kafka {
bootstrap_servers => ["IP_ADDRESS_XXXXX:9092"]
topics => ["topic1"]

(Youssef El) #3

This is what i got in the error message with 9092 and 6667 ports .

[2018-11-21T15:27:22,972][WARN ][org.apache.kafka.clients.NetworkClient] [Consumer clientId=logstash-0, groupId=logstash] Connection to node -1 could not be established. Broker may not be available.

(system) closed #4

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.