This is a common error when you start working with Kafka. Pretty much every Kafka developer has seen this error at least once.<\/p>\n\n\n\n

Problem<\/h2>\n\n\n\n

You might encounter the below error message when your Kafka consumers or clients connect to Kafka broker for ingestion or consumption.<\/p>\n\n\n\n

Connection to node -1 (\/127.0.0.1:9092) could not be established. Broker may not be available.<\/pre>\n\n\n\n
You might also see warnings like below<\/p>\n\n\n\n
[2017-09-11 16:21:18,998] WARN Connection to node 0 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) \n\n[2017-09-11 16:21:21,991] WARN Connection to node 0 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)<\/pre>\n\n\n\n
You could see this issue even when you properly refer to the Kafka brokers with their IP or hostname in your code or in your client scripts.<\/p>\n\n\n\n
Solution<\/h2>\n\n\n\n
Pay attention to the below 2 properties in the <kafka-install-dir>\/config\/server.properties.<\/p>\n\n\n\n
Under the Socket Server Settings – this setting controls where the host will listen to. The listener name (or host) is derived by Kafka by calling this Java method – java.net.InetAddress.getCanonicalHostName()<\/p>\n\n\n\n
Based on how the host is configured this can return localhost or hostname or 127.0.0.1\u00a0<\/p>\n\n\n\n
############################# Socket Server Settings #############################\r\n\r\n# The address the socket server listens on. If not configured, the host name will be equal to the value of\r\n# java.net.InetAddress.getCanonicalHostName(), with PLAINTEXT listener name, and port 9092.\r\n#   FORMAT:\r\n#     listeners = listener_name:\/\/host_name:port\r\n#   EXAMPLE:\r\n#     listeners = PLAINTEXT:\/\/your.host.name:9092\r\n#listeners=PLAINTEXT:\/\/:9092\r<\/pre>\n\n\n\n
Next, focus your attention to the advertised.listeners setting. This setting is very important. This setting controls how the broker advertises listener name, hostname and port to clients.<\/p>\n\n\n\n
If not explicitly set, this will return the value of listeners property. If the value of the listeners property has the correct IP or the hostname of the broker, there won\u2019t be any issues for the clients connecting to the broker.<\/p>\n\n\n\n
But, if the value of the listeners property return 127.0.0.1 or localhost, then the client attempting connection to the broker will not find the broker on 127.0.0.1 or localhost because they refer to the host that the client or consumer is running on.<\/p>\n\n\n\n
# Listener name, hostname and port the broker will advertise to clients.\r\n# If not set, it uses the value for \"listeners\".\r\n#advertised.listeners=PLAINTEXT:\/\/your.host.name:9092\n<\/pre>\n\n\n\n
Fix<\/h3>\n\n\n\n
Explicitly provide the hostname or ip address of the host of the broker in server.properties for both listeners and advertised.listeners.<\/p>\n\n\n\n
listeners=PLAINTEXT:\/\/birw-node-1:9092\r\n\r\nadvertised.listeners=PLAINTEXT:\/\/\/birw-node-1:9092\r\n<\/pre>\n\n\n\n
KRaft<\/h2>\n\n\n\n
This section doesn\u2019t apply to you if you are not using KRaft.<\/p>\n\n\n\n
Apache Kafka Raft (KRaft) is the consensus protocol that was introduced to remove Apache Kafka\u2019s dependency on ZooKeeper for metadata management. This greatly simplifies Kafka\u2019s architecture by consolidating responsibility for metadata into Kafka itself, rather than splitting it between two different systems: ZooKeeper and Kafka. KRaft mode makes use of a new quorum controller service in Kafka which replaces the previous controller and makes use of an event-based variant of the Raft consensus protocol.<\/p>\n\n\n\n
Please note: KRaft is in early access and should be used in development only. It is not suitable for production.<\/p>\n\n\n\n
If you are using KRaft, then you will see another server.properties under <kafka-install-dir>\/config\/kraft\/server.properties<\/p>\n\n\n\n
Explicitly set IP address or hostname in listeners and advertised.listeners in server.properties under kraft folder.<\/p>\n","protected":false},"excerpt":{"rendered":"
This is a common error when you start working with Kafka. Pretty much every Kafka developer has seen this error at least once. Problem You might [\u2026]<\/span><\/p>\n","protected":false},"author":3,"featured_media":0,"comment_status":"closed","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[15],"tags":[],"class_list":["post-2270","post","type-post","status-publish","format-standard","hentry","category-kafka"],"yoast_head":"\n