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

Stack Overflow | jones189 | 4 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 | 4 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 | 7 months ago | fady zohdy
    java.lang.ClassCastException: kafka.cluster.BrokerEndPoint cannot be cast to kafka.cluster.Broker
  3. 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
  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: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