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

Stack Overflow | fady zohdy | 7 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

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

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

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

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

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

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

    Automated exception search integrated into your IDE

  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
  6. 0

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

    Stack Overflow | 12 months ago | kk1957
    java.lang.ClassCastException: kafka.cluster.BrokerEndPoint cannot be cast to kafka.cluster.Broker

    1 unregistered visitors

    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:90)
      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:90)
      2. org.apache.spark.streaming.kafka.KafkaCluster$$anonfun$2$$anonfun$3$$anonfun$apply$6.apply(KafkaCluster.scala:87)
      2 frames
    5. Scala
      AbstractTraversable.flatMap
      1. scala.collection.TraversableLike$$anonfun$flatMap$1.apply(TraversableLike.scala:241)
      2. scala.collection.TraversableLike$$anonfun$flatMap$1.apply(TraversableLike.scala:241)
      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:241)
      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:87)
      2. org.apache.spark.streaming.kafka.KafkaCluster$$anonfun$2$$anonfun$3.apply(KafkaCluster.scala:86)
      2 frames
    7. Scala
      AbstractTraversable.flatMap
      1. scala.collection.TraversableLike$$anonfun$flatMap$1.apply(TraversableLike.scala:241)
      2. scala.collection.TraversableLike$$anonfun$flatMap$1.apply(TraversableLike.scala:241)
      3. scala.collection.immutable.Set$Set1.foreach(Set.scala:94)
      4. scala.collection.TraversableLike$class.flatMap(TraversableLike.scala:241)
      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:86)
      2. org.apache.spark.streaming.kafka.KafkaCluster$$anonfun$2.apply(KafkaCluster.scala:85)
      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:85)
      2. org.apache.spark.streaming.kafka.KafkaCluster.getLeaderOffsets(KafkaCluster.scala:179)
      3. org.apache.spark.streaming.kafka.KafkaCluster.getLeaderOffsets(KafkaCluster.scala:161)
      4. org.apache.spark.streaming.kafka.KafkaCluster.getEarliestLeaderOffsets(KafkaCluster.scala:155)
      5. org.apache.spark.streaming.kafka.KafkaUtils$$anonfun$5.apply(KafkaUtils.scala:213)
      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)
      2 frames
    13. Unknown
      SparkStreaming$delayedInit$body.apply
      1. SparkStreaming$.delayedEndpoint$SparkStreaming$1(SparkStreaming.scala:32)
      2. SparkStreaming$delayedInit$body.apply(SparkStreaming.scala:24)
      2 frames
    14. Scala
      App$class.main
      1. scala.Function0$class.apply$mcV$sp(Function0.scala:34)
      2. scala.runtime.AbstractFunction0.apply$mcV$sp(AbstractFunction0.scala:12)
      3. scala.App$$anonfun$main$1.apply(App.scala:76)
      4. scala.App$$anonfun$main$1.apply(App.scala:76)
      5. scala.collection.immutable.List.foreach(List.scala:381)
      6. scala.collection.generic.TraversableForwarder$class.foreach(TraversableForwarder.scala:35)
      7. scala.App$class.main(App.scala:76)
      7 frames
    15. Unknown
      SparkStreaming.main
      1. SparkStreaming$.main(SparkStreaming.scala:24)
      2. SparkStreaming.main(SparkStreaming.scala)
      2 frames
    16. 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:497)
      4 frames
    17. IDEA
      AppMain.main
      1. com.intellij.rt.execution.application.AppMain.main(AppMain.java:144)
      1 frame