java.lang.ClassCastException: kafka.cluster.BrokerEndPoint cannot be cast to kafka.cluster.Broker

Stack Overflow | jones189 | 5 months ago
tip
Do you know that we can give you better hits? Get more relevant results from Samebug’s stack trace search.
  1. 0

    Why do I get kafka.cluster.BrokerEndPoint cannot be cast to kafka.cluster.Broker?

    Stack Overflow | 5 months ago | jones189
    java.lang.ClassCastException: kafka.cluster.BrokerEndPoint cannot be cast to kafka.cluster.Broker
  2. 0

    kafka.cluster.BrokerEndPoint cannot be cast to kafka.cluster.Broker

    Stack Overflow | 8 months ago | fady zohdy
    java.lang.ClassCastException: kafka.cluster.BrokerEndPoint cannot be cast to kafka.cluster.Broker
  3. Speed up your debug routine!

    Automated exception search integrated into your IDE

  4. 0

    Spark Streaming Kafka integration in CDH 5.8.3 in yarn-cluster mode

    Stack Overflow | 3 months ago | mgaido
    java.lang.ClassCastException: kafka.cluster.Broker cannot be cast to kafka.cluster.BrokerEndPoint
  5. 0

    Spark Streaming Kafka stream

    Stack Overflow | 1 year ago | besil
    java.lang.ClassCastException: kafka.cluster.BrokerEndPoint cannot be cast to kafka.cluster.Broker

    1 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.lang.ClassCastException

      kafka.cluster.BrokerEndPoint cannot be cast to kafka.cluster.Broker

      at org.apache.spark.streaming.kafka.KafkaCluster$$anonfun$2$$anonfun$3$$anonfun$apply$6$$anonfun$apply$7.apply()
    2. Spark Project External Kafka
      KafkaCluster$$anonfun$2$$anonfun$3$$anonfun$apply$6$$anonfun$apply$7.apply
      1. org.apache.spark.streaming.kafka.KafkaCluster$$anonfun$2$$anonfun$3$$anonfun$apply$6$$anonfun$apply$7.apply(KafkaCluster.scala:97)
      1 frame
    3. Scala
      Option.map
      1. scala.Option.map(Option.scala:146)
      1 frame
    4. Spark Project External Kafka
      KafkaCluster$$anonfun$2$$anonfun$3$$anonfun$apply$6.apply
      1. org.apache.spark.streaming.kafka.KafkaCluster$$anonfun$2$$anonfun$3$$anonfun$apply$6.apply(KafkaCluster.scala:97)
      2. org.apache.spark.streaming.kafka.KafkaCluster$$anonfun$2$$anonfun$3$$anonfun$apply$6.apply(KafkaCluster.scala:94)
      2 frames
    5. Scala
      AbstractTraversable.flatMap
      1. scala.collection.TraversableLike$$anonfun$flatMap$1.apply(TraversableLike.scala:252)
      2. scala.collection.TraversableLike$$anonfun$flatMap$1.apply(TraversableLike.scala:252)
      3. scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:33)
      4. scala.collection.mutable.WrappedArray.foreach(WrappedArray.scala:35)
      5. scala.collection.TraversableLike$class.flatMap(TraversableLike.scala:252)
      6. scala.collection.AbstractTraversable.flatMap(Traversable.scala:104)
      6 frames
    6. Spark Project External Kafka
      KafkaCluster$$anonfun$2$$anonfun$3.apply
      1. org.apache.spark.streaming.kafka.KafkaCluster$$anonfun$2$$anonfun$3.apply(KafkaCluster.scala:94)
      2. org.apache.spark.streaming.kafka.KafkaCluster$$anonfun$2$$anonfun$3.apply(KafkaCluster.scala:93)
      2 frames
    7. Scala
      AbstractTraversable.flatMap
      1. scala.collection.TraversableLike$$anonfun$flatMap$1.apply(TraversableLike.scala:252)
      2. scala.collection.TraversableLike$$anonfun$flatMap$1.apply(TraversableLike.scala:252)
      3. scala.collection.immutable.Set$Set1.foreach(Set.scala:79)
      4. scala.collection.TraversableLike$class.flatMap(TraversableLike.scala:252)
      5. scala.collection.AbstractTraversable.flatMap(Traversable.scala:104)
      5 frames
    8. Spark Project External Kafka
      KafkaCluster$$anonfun$2.apply
      1. org.apache.spark.streaming.kafka.KafkaCluster$$anonfun$2.apply(KafkaCluster.scala:93)
      2. org.apache.spark.streaming.kafka.KafkaCluster$$anonfun$2.apply(KafkaCluster.scala:92)
      2 frames
    9. Scala
      Either$RightProjection.flatMap
      1. scala.util.Either$RightProjection.flatMap(Either.scala:522)
      1 frame
    10. Spark Project External Kafka
      KafkaUtils$$anonfun$5.apply
      1. org.apache.spark.streaming.kafka.KafkaCluster.findLeaders(KafkaCluster.scala:92)
      2. org.apache.spark.streaming.kafka.KafkaCluster.getLeaderOffsets(KafkaCluster.scala:186)
      3. org.apache.spark.streaming.kafka.KafkaCluster.getLeaderOffsets(KafkaCluster.scala:168)
      4. org.apache.spark.streaming.kafka.KafkaCluster.getLatestLeaderOffsets(KafkaCluster.scala:157)
      5. org.apache.spark.streaming.kafka.KafkaUtils$$anonfun$5.apply(KafkaUtils.scala:215)
      6. org.apache.spark.streaming.kafka.KafkaUtils$$anonfun$5.apply(KafkaUtils.scala:211)
      6 frames
    11. Scala
      Either$RightProjection.flatMap
      1. scala.util.Either$RightProjection.flatMap(Either.scala:522)
      1 frame
    12. Spark Project External Kafka
      KafkaUtils.createDirectStream
      1. org.apache.spark.streaming.kafka.KafkaUtils$.getFromOffsets(KafkaUtils.scala:211)
      2. org.apache.spark.streaming.kafka.KafkaUtils$.createDirectStream(KafkaUtils.scala:484)
      3. org.apache.spark.streaming.kafka.KafkaUtils$.createDirectStream(KafkaUtils.scala:607)
      4. org.apache.spark.streaming.kafka.KafkaUtils.createDirectStream(KafkaUtils.scala)
      4 frames
    13. Unknown
      SparkStream.main
      1. SparkStream.main(SparkStream.java:28)
      1 frame
    14. Java RT
      Method.invoke
      1. sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
      2. sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
      3. sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
      4. java.lang.reflect.Method.invoke(Method.java:498)
      4 frames
    15. IDEA
      AppMain.main
      1. com.intellij.rt.execution.application.AppMain.main(AppMain.java:147)
      1 frame