kafka.common.KafkaException: fetching topic metadata for topics [Set(test)] from broker [ArrayBuffer(BrokerEndPoint(0,ba762186182f,9092))] failed

Stack Overflow | Jonathan | 3 months ago
  1. 0

    kafka on kubernetes cannot produce/consume topics (ClosedChannelException, ErrorLoggingCallback)

    Stack Overflow | 6 months ago | Pao
    kafka.common.KafkaException: fetching topic metadata for topics [Set(test)] from broker [ArrayBuffer(BrokerEndPoint(1001,kafka-service,9092))] failed
  2. 0

    GitHub comment 54#230603311

    GitHub | 5 months ago | spujadas
    kafka.common.KafkaException: fetching topic metadata for topics [Set(test)] from broker [ArrayBuffer(BrokerEndPoint(0,elkdockeres233-l232-k451-2gb-fra1-01,9092))] failed
  3. 0

    GitHub comment 26594#247298574

    GitHub | 3 months ago | Richard-Mathie
    kafka.common.KafkaException: fetching topic metadata for topics [Set(test)] from broker [ArrayBuffer(BrokerEndPoint(1001,192.168.99.101,9092), BrokerEndPoint(1002,192.168.99.100,9092))] failed
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    Kafka Docker - Can't produce or consume from outside of docker container

    Stack Overflow | 3 months ago | Jonathan
    kafka.common.KafkaException: fetching topic metadata for topics [Set(test)] from broker [ArrayBuffer(BrokerEndPoint(0,ba762186182f,9092))] failed
  6. 0

    Logstash (1.5.3) is not able to get data from remote kafka

    GitHub | 1 year ago | debraj-manna
    kafka.common.KafkaException: fetching topic metadata for topics [Set(logstash_logs)] from broker [ArrayBuffer(id:0,host:localhost,port:9092)] failed

  1. max_samebug 2408 times, last 3 months ago
3 unregistered visitors
Not finding the right solution?
Take a tour to get the most out of Samebug.

Tired of useless tips?

Automated exception search integrated into your IDE

Root Cause Analysis

  1. java.nio.channels.ClosedChannelException

    No message provided

    at kafka.network.BlockingChannel.send()
  2. Apache Kafka
    ShutdownableThread.run
    1. kafka.network.BlockingChannel.send(BlockingChannel.scala:110)
    2. kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:80)
    3. kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:79)
    4. kafka.producer.SyncProducer.send(SyncProducer.scala:124)
    5. kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:59)
    6. kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:94)
    7. kafka.consumer.ConsumerFetcherManager$LeaderFinderThread.doWork(ConsumerFetcherManager.scala:66)
    8. kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63)
    8 frames