java.lang.NoClassDefFoundError: org/apache/kafka/common/utils/Utils

kafka-users | Marty B | 2 years ago
tip
Click on the to mark the solution that helps you, Samebug will learn from it.
As a community member, you’ll be rewarded for you help.
  1. 0

    Re: Spark Streaming - Failed to find leader

    apache.org | 1 year ago
    java.lang.NoClassDefFoundError: org/apache/kafka/common/utils/Utils
  2. 0

    Re: Spark Streaming - Failed to find leader

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

    Root Cause Analysis

    1. java.lang.NoClassDefFoundError

      org/apache/kafka/common/utils/Utils

      at kafka.cluster.Broker.connectionString()
    2. Apache Kafka
      ClientUtils$$anonfun$fetchTopicMetadata$5.apply
      1. kafka.cluster.Broker.connectionString(Broker.scala:62)
      2. kafka.client.ClientUtils$$anonfun$fetchTopicMetadata$5.apply(ClientUtils.scala:89)
      3. kafka.client.ClientUtils$$anonfun$fetchTopicMetadata$5.apply(ClientUtils.scala:89)
      3 frames
    3. Scala
      AbstractTraversable.map
      1. scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:244)
      2. scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:244)
      3. scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:59)
      4. scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:47)
      5. scala.collection.TraversableLike$class.map(TraversableLike.scala:244)
      6. scala.collection.AbstractTraversable.map(Traversable.scala:105)
      6 frames
    4. Apache Kafka
      ShutdownableThread.run
      1. kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:89)
      2. kafka.consumer.ConsumerFetcherManager$LeaderFinderThread.doWork(ConsumerFetcherManager.scala:66)
      3. kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:60)
      3 frames