Leader Not Available Kafka in Console Producer

Question

I am trying to use Kafka  All configurations are done properly but when I try to produce message from console I keep getting the following error  WARN Error while fetching metadata with correlation id 39          4-3-16-topic1 LEADER NOT AVAILABLE   org apache kafka clients NetworkClient    Kafka version  2 11-0 9 0 0

User · Answer

Try this listeners PLAINTEXT   localhost 9092 It must be helpful Many thanks

User · Answer

Adding this since it may help others  A Common problem can be a misconfiguration of advertised host name  With Docker using docker-compose setting the name of the service inside KAFKA ADVERTISED HOST NAME wont work unless you set the hostname as well  docker-compose yml example     kafka      image  wurstmeister kafka     ports        -  9092 9092      hostname  kafka     environment        KAFKA ADVERTISED HOST NAME  kafka       KAFKA CREATE TOPICS   test 1 1        KAFKA ZOOKEEPER CONNECT  zookeeper 2181     volumes        -  var run docker sock  var run docker sock   The above without hostname  kafka can issue a LEADER NOT AVAILABLE when trying to connect  You can find an example of a working docker-compose configuration here

User · Answer

Another possibility for this warning  in 0 10 2 1  is that you try to poll on a topic that has just been created and the leader for this topic-partition is not yet available  you are in the middle of a leadership election   Waiting a second between topic creation and polling is a workaround

User · Answer

If you are running kafka on local machine  try updating  KAFKA DIR config server properties with below line  listeners PLAINTEXT   localhost 9092 and then restarting kafka

User · Answer

In my case  it was working fine at home  but it was failing in office  the moment I connect to office network   So modified the config server properties listeners PLAINTEXT    9092 to listeners PLAINTEXT   localhost 9092  In my case  I was getting while describing the Consumer Group

User · Answer

I tried all the recommendations listed here  What worked for me was to go to server properties and add   port   9092 advertised host name   localhost    Leave listeners and advertised listeners commented out

User · Answer

This below line I have added in config server properties  that resolved my issue similar above issue  Hope this helps  its pretty much well documented in server properties file  try to read and understand before you modify this  advertised listeners PLAINTEXT    lt your kafka server ip gt  9092

User · Answer

For me  I didn t specify broker id for Kafka instance  It will get a new id from zookeeper sometimes when it restarts in Docker environment  If your broker id is greater than 1000  just specify the environment variable KAFKA BROKER ID   Use this to see brokers  topics and partitions   brew install kafkacat kafkacat -b  kafka ip   kafka poot  -L

User · Answer

I had kafka running as a Docker container and similar messages were flooding to the log  And KAFKA ADVERTISED HOST NAME was set to  kafka      In my case the reason for error was the missing  etc hosts record for  kafka  in  kafka  container itself  So  for example  running ping kafka inside  kafka  container would fail with ping  bad address  kafka     In terms of Docker this problem gets solved by specifying hostname for the container     Options to achieve it     docker run --hostname      docker run -it --add-host     hostname in docker-compose hostname in AWS EC2 Task Definition

User · Answer

Issue is resolved after adding the listener setting on server properties file located at config directory   listeners PLAINTEXT   localhost or your server  9092 Restart kafka after this change  Version used 2 11

User · Answer

i know this was posted long time back  i would like to share how i solved it  since i have my office laptop   VPN and proxy was configured    i checked the environment variable NO PROXY     gt  echo  NO PROXY    it returned with empty values now i have set the NO PROXY with localhost and 127 0 0 1     gt  set NO PROXY 127 0 0 1 localhost     if you want to append to existing values  then     gt  set NO PROXY  NO PROXY  127 0 0 1 localhost     after this   i have restarted zookeeper and kafka worked like a charm

User · Answer

For me  it was happen due to a miss configuration Docker port  9093  Kafka command port  bin kafka-console-producer sh --broker-list localhost 9092 --topic TopicName  I checked my configuration to match port and now everything is ok

User · Answer

What solved it for me is to set listeners like so   advertised listeners   PLAINTEXT   my public ip 9092 listeners   PLAINTEXT   0 0 0 0 9092   This makes KAFKA broker listen to all interfaces

User · Answer

For anyone trying to run kafka on kubernetes and running into this error  this is what finally solved it for me   You have to either    Add hostname to the pod spec  that way kafka can find itself    or   If using hostPort  then you need hostNetwork  true and dnsPolicy  ClusterFirstWithHostNet   The reason for this is because Kafka needs to talk to itself  and it decides to use the  advertised  listener hostname to find itself  rather than using localhost  Even if you have a Service that points the advertised host name at the pod  it is not visible from within the pod  I do not really know why that is the case  but at least there is a workaround   apiVersion  extensions v1beta1 kind  Deployment metadata    name  zookeeper-cluster1   namespace  default   labels      app  zookeeper-cluster1 spec    replicas  1   selector      matchLabels        app  zookeeper-cluster1   template      metadata        labels          name  zookeeper-cluster1         app  zookeeper-cluster1     spec        hostname  zookeeper-cluster1       containers        - name  zookeeper-cluster1         image  wurstmeister zookeeper latest         imagePullPolicy  IfNotPresent         ports          - containerPort  2181         - containerPort  2888         - containerPort  3888  ---  apiVersion  v1 kind  Service metadata    name  zookeeper-cluster1   namespace  default   labels      app  zookeeper-cluster1 spec    type  NodePort   selector      app  zookeeper-cluster1   ports    - name  zookeeper-cluster1     protocol  TCP     port  2181     targetPort  2181   - name  zookeeper-follower-cluster1     protocol  TCP     port  2888     targetPort  2888   - name  zookeeper-leader-cluster1     protocol  TCP     port  3888     targetPort  3888  ---  apiVersion  extensions v1beta1 kind  Deployment metadata    name  kafka-cluster   namespace  default   labels      app  kafka-cluster spec    replicas  1   selector      matchLabels        app  kafka-cluster   template      metadata        labels          name  kafka-cluster         app  kafka-cluster     spec        hostname  kafka-cluster       containers        - name  kafka-cluster         image  wurstmeister kafka latest         imagePullPolicy  IfNotPresent         env          - name  KAFKA ADVERTISED LISTENERS           value  PLAINTEXT   kafka-cluster 9092         - name  KAFKA ZOOKEEPER CONNECT           value  zookeeper-cluster1 2181         ports          - containerPort  9092  ---  apiVersion  v1 kind  Service metadata    name  kafka-cluster   namespace  default   labels      app  kafka-cluster spec    type  NodePort   selector      app  kafka-cluster   ports    - name  kafka-cluster     protocol  TCP     port  9092     targetPort  9092

User · Answer

I am using docker-compose to build the Kafka container using wurstmeister kafka image  Adding KAFKA ADVERTISED PORT  9092 property to my docker-compose file solved this error for me

User · Answer

For me  the cause was using a specific Zookeeper that was not part of the Kafka package  That Zookeeper was already installed on the machine for other purposes  Apparently Kafka does not work with just any Zookeeper  Switching to the Zookeeper that came with Kafka solved it for me  To not conflict with the existing Zookeeper  I had to modify my confguration to have the Zookeeper listen on a different port    root host  opt kafka config   grep 2182   server properties zookeeper connect localhost 2182 zookeeper properties clientPort 2182

User · Answer

When LEADER NOT AVAILABLE error throws  just restart the kafka broker    bin kafka-server-stop sh   followed by    bin kafka-server-start sh config server properties    Note  Zookeeper must be running by this time  if you do otherway it wont work

User · Answer

I m using kafka 2 12-0 10 2 1   vi config server properties  add below line   listeners PLAINTEXT   localhost 9092    No need to change the advertised listeners as it picks up the value from std listener property    Hostname and port the broker will advertise to producers and consumers  If not set     it uses the value for  listeners  if configured   Otherwise  it will use the value returned from java net InetAddress getCanonicalHostName     stop the Kafka broker   bin kafka-server-stop sh   restart broker   bin kafka-server-start sh -daemon config server properties   and now you should not see any issues

User · Answer

We tend to get this message when we try to subscribe to a topic that has not been created yet   We generally rely on topics to be created a priori in our deployed environments  but we have component tests that run against a dockerized kafka instance  which starts clean every time     In that case  we use AdminUtils in our test setup to check if the topic exists and create it if not   See this other stack overflow for more about setting up AdminUtils

User · Answer

If you get repeated error messages like this  Error while fetching metadata with correlation id 3991    your topic LEADER NOT AVAILABLE   Or Discovered group coordinator 172 25 1 2 9092  id  2147483645 rack  null   org apache kafka clients consumer internals AbstractCoordinator 677   Re- joining group  org apache kafka clients consumer internals AbstractCoordinator 509  Group coordinator 172 25 1 2 9092  id  2147483645 rack  null  is unavailable or invalid  will attempt rediscovery  org apache kafka clients consumer internals AbstractCoordinator 729  Discovered group coordinator 172 25 40 219 9092  id  2147483645 rack  null   org apache kafka clients consumer internals AbstractCoordinator 677  Group coordinator 172 25 1 2 9092  id  2147483645 rack  null  is unavailable or invalid  will attempt rediscovery  org apache kafka clients consumer internals AbstractCoordinator 729   Then  you need to configure listener settings like this in the kafka server properties   listeners PLAINTEXT   your server ip 9092  This is the solution tried on Apacke Kafka 2 5 0 and confluent platform 5 4 1

User · Answer

For all those struggling with the Kafka ssl setup and seeing this LEADER NOT AVAILABLE error  One of the reasons that might be broken is the keystore and truststore  In the keystore you need to have private key of the server   signed server certificate  In the client truststore  you need to have intermedidate CA certificate so that client can authenticate the kafka server  If you will use ssl for interbroker communication  you need this truststore also set in the server properties of the brokers so they can authenticate each other   That last piece I was mistakenly missing and caused me a lot of painful hours finding out what this LEADER NOT AVAILABLE error might mean  Hopefully this can help somebody

User · Answer

Since I wanted my kafka broker to connect with remote producers and consumers  So  I don t want advertised listener to be commented out  In my case   running kafka on kubernetes   I found out that my kafka pod was not assigned any Cluster IP  By removing the line clusterIP  None from services yml   the kubernetes assigns an internal-ip to kafka pod  This resolved my issue of LEADER NOT AVAILABLE and also remote connection of kafka producers consumers

User · Answer

I have been witnessing this same issue in the last 2 weeks while working with Kafka and have been reading this Stackoverflow s post ever since      After 2 weeks of analysis i have deduced that in my case this happens   when trying to produce messages to a topic that doesn t exist     The outcome in my case is that Kafka sends an error message back but creates  at the same time  the topic that did not exist before  So if I try to produce any message again to that topic after this event  the error will not appear anymore as the topic as been created   PLEASE NOTE  It could be that my particular Kafka installation was configured to automatically create the topic when the same does not exist  that should explain why in my case I can see the issue only once for every topic after resetting the topics  your configuration might be different and in that case you would keep receiving the same error over and over   Regards   Luca Tampellini

User · Answer

The advertised listeners as mentioned in the above answers could be one of the reason  The other possible reasons are    The topic might not have been created  You can check this using bin kafka-topics --list --zookeeper  lt zookeeper ip gt   lt zookeeper port gt  Check your bootstrap servers that you have given to the producer to fetch the metadata  If the bootstrap server does not contain the latest metadata about the topic  for example  when it lost its zookeeper claim   You must be adding more than one bootstrap servers    Also  ensure that you have the advertised listener set to IP 9092 instead of localhost 9092  The latter means that the broker is accessible only through the localhost   When I encountered the error  I remember to have used PLAINTEXT    lt ip gt   lt PORT gt  in the list of bootstrap servers  or broker list  and it worked  strangely   bin kafka-console-producer --topic sample --broker-list PLAINTEXT    lt IP gt   lt PORT gt

User · Answer

It could be related to advertised host name setting in your server properties   What could happen is that your producer is trying to find out who is the leader for a given partition  figures out its advertised host name and advertised port and tries to connect  If these settings are not configured correctly it then may think that the leader is unavailable

[apache-kafka] Leader Not Available Kafka in Console Producer

Examples related to apache-kafka

Examples related to producer