kafka.common.BrokerEndPointNotAvailableException: End point PLAINTEXT not found for broker 186

Stack Overflow | jifei yang | 2 months ago
tip
Do you find the tips below useful? Click on the to mark them and say thanks to rafael . Or join the community to write better ones.
  1. 0

    End point PLAINTEXT not found for broker 186

    Stack Overflow | 2 months ago | jifei yang
    kafka.common.BrokerEndPointNotAvailableException: End point PLAINTEXT not found for broker 186
  2. 0

    ssl endpoints?

    GitHub | 11 months ago | dmead
    kafka.common.BrokerEndPointNotAvailableException: End point PLAINTEXT not found for broker 1
  3. 0
    samebug tip
    Maybe you're using the wrong version of kafka-clients for your core code. Try to have the same version of both of them.
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    Re: Spark Streaming - Failed to find leader

    kafka-users | 2 years ago | Marty B
    java.lang.NoClassDefFoundError: org/apache/kafka/common/utils/Utils
  6. 0

    Re: Spark Streaming - Failed to find leader

    apache.org | 2 years ago
    java.lang.NoClassDefFoundError: org/apache/kafka/common/utils/Utils

    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. kafka.common.BrokerEndPointNotAvailableException

      End point PLAINTEXT not found for broker 186

      at kafka.cluster.Broker.getBrokerEndPoint()
    2. Apache Kafka
      ZkUtils$$anonfun$getAllBrokerEndPointsForChannel$1.apply
      1. kafka.cluster.Broker.getBrokerEndPoint(Broker.scala:141)
      2. kafka.utils.ZkUtils$$anonfun$getAllBrokerEndPointsForChannel$1.apply(ZkUtils.scala:171)
      3. kafka.utils.ZkUtils$$anonfun$getAllBrokerEndPointsForChannel$1.apply(ZkUtils.scala:171)
      3 frames
    3. Scala
      AbstractTraversable.map
      1. scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:245)
      2. scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:245)
      3. scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:59)
      4. scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:48)
      5. scala.collection.TraversableLike$class.map(TraversableLike.scala:245)
      6. scala.collection.AbstractTraversable.map(Traversable.scala:104)
      6 frames
    4. Apache Kafka
      ShutdownableThread.run
      1. kafka.utils.ZkUtils.getAllBrokerEndPointsForChannel(ZkUtils.scala:171)
      2. kafka.consumer.ConsumerFetcherManager$LeaderFinderThread.doWork(ConsumerFetcherManager.scala:65)
      3. kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63)
      3 frames