kafka.common.KafkaException

fetching topic metadata for topics [Set(default)] from broker [List()] failed


Solutions on the web117

Solution icon of github
via GitHub by ingenthr
, 1 year ago
fetching topic metadata for topics [Set(default)] from broker [List()] failed

Solution icon of couchbase
via Couchbase JIRA by Andrei Baranouski, 1 year ago
fetching topic metadata for topics [Set(default)] from broker [List()] failed

Solution icon of github
fetching topic metadata for topics [Set(default)] from broker [List()] failed

Solution icon of couchbase
via Couchbase JIRA by Andrei Baranouski, 1 year ago
fetching topic metadata for topics [Set(default)] from broker [List()] failed

Solution icon of stackoverflow
fetching topic metadata for topics [Set(fulfillment.payments.autopay.listeddueaccounts)] from broker [List()] failed

Solution icon of stackoverflow
fetching topic metadata for topics [Set(page_visits)] from broker [ArrayBuffer(BrokerEndPoint(0,sandbox.hortonworks.com,9092))] failed

Solution icon of stackoverflow
via Stack Overflow by Learner
, 9 months ago
fetching topic metadata for topics [Set(SAMPLETOPIC)] from broker [ArrayBuffer(BrokerEndPoint(0,sample.node,9093))] failed

Solution icon of stackoverflow
fetching topic metadata for topics [Set(mydata)] from broker [ArrayBuffer(id:0,host:MYServer,port:9082)] failed

Solution icon of stackoverflow
fetching topic metadata for topics [Set(topicname)] from broker [ArrayBuffer(id:0,host:xxx.xxx.xxx.xxx,port:9092)] failed

Solution icon of github
fetching topic metadata for topics [Set(rsyslog_logstash)] from broker [ArrayBuffer()] failed

Stack trace

  • kafka.common.KafkaException: fetching topic metadata for topics [Set(default)] from broker [List()] failed at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:72) at kafka.producer.BrokerPartitionInfo.updateInfo(BrokerPartitionInfo.scala:82) at kafka.producer.async.DefaultEventHandler$$anonfun$handle$1.apply$mcV$sp(DefaultEventHandler.scala:67) at kafka.utils.Utils$.swallow(Utils.scala:172) at kafka.utils.Logging$class.swallowError(Logging.scala:106) at kafka.utils.Utils$.swallowError(Utils.scala:45) at kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:67) at kafka.producer.Producer.send(Producer.scala:77) at kafka.javaapi.producer.Producer.send(Producer.scala:33) at com.couchbase.kafka.KafkaWriter.onEvent(KafkaWriter.java:75) at com.couchbase.kafka.KafkaWriter.onEvent(KafkaWriter.java:36) at com.couchbase.client.deps.com.lmax.disruptor.BatchEventProcessor.run(BatchEventProcessor.java:128) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) at com.couchbase.client.deps.io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:137) at java.lang.Thread.run(Thread.java:745)

Write tip

You have a different solution? A short tip here would help you and many other users who saw this issue last week.

Users with the same issue

Samebug visitor profile picture
Unknown user
Once, 1 year ago
Samebug visitor profile picture
Unknown user
Once, 1 year ago
2408 times, 11 months ago
Samebug visitor profile picture
Unknown user
Once, 1 year ago