• Register
0 votes
2.3k views

Problem :

I am trying to produce the message in kafka, but i am getting the following error :

Error when sending message to topic nil_PF1_P1 with key: null, value: 2 bytes with error: (org.apache.kafka.clients.producer.internals.ErrorLoggingCallback)
org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms.
Error when sending message to topic nil_PF1_P1 with key: null, value: 5 bytes with error: (org.apache.kafka.clients.producer.internals.ErrorLoggingCallback)
org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms.
Any suggestions on this issue??
6 5 3
7,540 points

Please log in or register to answer this question.

1 Answer

0 votes

Solution :

I also had the same issue in recent past with confluent_kafka 0.9.2 (0x90200) and librdkafka 0.9.2 (0x90401). In my case, the issue was that I specified the wrong broker port number as follows:

$ kafka-console-producer.sh --broker-list localhost:9092 --topic tutorialpoint-basic-ops-01

And my brokers port number was 9094 as follows:

$ cat server-02.properties

broker.id=2

port=9094

log.dirs=/tmp/kafka-example-logs-02

zookeeper.connect=localhost:2181

But the 9092 port was not open (netstat -tunap), it took 60s for kafka-console-producer.sh to raise an error. Looks like this tool needs a fix to:

·         fail faster

·         with a more explicit error message.

OR

If by any chance you are running hortonworks cluster then you must check the listening port in ambari.

In my case the 9092 was not my port at all. When I went to ambari and checked there I found the listening port was set to 6667 I changed it and it worked for me. :)

9 7 4
38,600 points

Related questions

1 vote
1 answer 161 views
161 views
Problem : Currently I am using Hadoop 2.7.1 and apache-hive-1.2.1 versions installed on my ubuntu 14.0. 1. Why below error is occurring ? 2. Do I need to do metastore installation ? 3. When we are typing the hive command on terminal how the ... Still the above error persist #HIVE home directory configuration export HIVE_HOME=/usr/local/hive/apache-hive-1.2.1-bin export PATH="$PATH:$HIVE_HOME/bin"
asked Dec 12, 2019 alecxe 7.5k points
0 votes
1 answer 43 views
43 views
Problem : Getting bellow error because of Maven Compiler Plugin failed to execute goal org.apache.maven.plugins:maven-compiler-plugin:3.1:compile (default-compile)
asked Nov 7, 2019 peterlaw 6.9k points
0 votes
1 answer 71 views
71 views
Problem: I think my Jenkins would ssh in and execute the commands described in a specific job which is running. Currently I want to run my Selenium Webdriver tests but unfortunately it informs me that I have many errors while trying to launch the firefox. I am also ... 45000 ms. Firefox console output: [testng] Xlib: connection to ":0.0" refused by server [testng] Xlib: No protocol specified
asked Jul 11, 2020 Raphael Pacheco 4.9k points
0 votes
1 answer 7 views
0 votes
1 answer 7 views
7 views
How can I solve this problem? can anyone help me?
asked Dec 19, 2020 TeamScript 11.1k points
0 votes
1 answer 42 views
42 views
Problem: I am new to Java. I am trying to write in the excel sheet using Java POI. I am facing below error: Exception in thread "main" java.lang.NoClassDefFoundError: org/apache/xmlbeans/XmlObject at OrderBook.WriteToExcelSheet.CreateOutPutFile(WriteToExcelSheet.java:20) at OrderBook. ... jar, poi-scratchpad-3.9-20121203.jar Now I am looking for the Java expert who can fix the above error for me.
asked Aug 17, 2020 Raphael Pacheco 4.9k points
0 votes
1 answer 825 views
825 views
Problem : I have a jsp code where I am trying to edit the information for a user of my web page. I am new to the jsp programming and I am experiencing below errors. When I try to run it, I get below error: org.apache.jasper.JasperException: ... also face below error: javax.servlet.ServletException: java.sql.SQLException: Column 'email' not found. java.sql.SQLException: Column 'email' not found.
asked Jan 24, 2020 jwilliam 3.9k points
0 votes
1 answer 1.3K views
1.3K views
Problem : When I run the apache tomcat7.0.56 in Eclipse, I get below error Error: Could not find or load main class org.apache.catalina.startup.Bootstrap How can I fix the above problem?
asked Jan 18, 2020 jwilliam 3.9k points
0 votes
1 answer 176 views
176 views
Problem : I have my Spark app which runs without any problem in the local mode, but have some problems when trying to submit to my Spark cluster. The error message is as below: 20/01/05 15:42:06 WARN scheduler.TaskSetManager: Lost task 2.0 in stage 0.0 (TID 2, ... but I have already provided the "--master" parameter to my spark-submit. Anybody who can fix above problem? My Spark version : 1.6.1
asked Jan 6, 2020 alecxe 7.5k points
0 votes
1 answer 833 views
833 views
Problem : Getting strange error related to constant pool as follows org.apache.tomcat.util.bcel.classfile.classformatexception: invalid byte tag in constant pool: 19
asked Nov 11, 2019 peterlaw 6.9k points