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

Stack Overflow | fady zohdy | 5 months ago
  1. 0

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

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

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

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

    Spark Streaming Kafka stream

    Stack Overflow | 1 year ago | besil
    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

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

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

    Memcached Java客户端2.6.1发布 - 编程语言 - ITeye资讯

    iteye.com | 1 year ago
    java.lang.ClassCastException: cannot be cast to

    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: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