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

Stack Overflow | jones189 | 2 months ago
  1. 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
  2. 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
  3. 0

    Spark Streaming Kafka stream

    Stack Overflow | 12 months 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: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