org.apache.spark.SparkException: Couldn't find leader offsets for Set([test2,0])

Stack Overflow | user1849773 | 4 months ago
  1. 0

    Connection spark streaming to kafka within eclipse: error-Couldn't find leader offsets

    Stack Overflow | 4 months ago | user1849773
    org.apache.spark.SparkException: Couldn't find leader offsets for Set([test2,0])
  2. 0

    GitHub comment 113#158861911

    GitHub | 1 year ago | ssamynathan
    org.apache.spark.SparkException: java.io.EOFException: Received -1 when reading from channel, socket has likely been closed.
  3. 0

    第91课:SparkStreaming基于Kafka Direct案例实战和内幕源码解密 java.lang.ClassNotFoundException 踩坑解决问题详细内幕版本

    csdn.net | 7 months ago
    org.apache.spark.SparkException: Error getting partition metadata for 'SparkStreamingDirected'. Does the topic  exist?
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    Spark Streaming Kafka Consumer

    Stack Overflow | 2 months ago | Ken Alton
    java.lang.reflect.InvocationTargetException

    6 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. org.apache.spark.SparkException

      Couldn't find leader offsets for Set([test2,0])

      at org.apache.spark.streaming.kafka.KafkaCluster$$anonfun$checkErrors$1.apply()
    2. Spark Project External Kafka
      KafkaCluster$$anonfun$checkErrors$1.apply
      1. org.apache.spark.streaming.kafka.KafkaCluster$$anonfun$checkErrors$1.apply(KafkaCluster.scala:373)
      2. org.apache.spark.streaming.kafka.KafkaCluster$$anonfun$checkErrors$1.apply(KafkaCluster.scala:373)
      2 frames
    3. Scala
      Either.fold
      1. scala.util.Either.fold(Either.scala:98)
      1 frame
    4. Spark Project External Kafka
      KafkaUtils.createDirectStream
      1. org.apache.spark.streaming.kafka.KafkaCluster$.checkErrors(KafkaCluster.scala:372)
      2. org.apache.spark.streaming.kafka.KafkaUtils$.getFromOffsets(KafkaUtils.scala:222)
      3. org.apache.spark.streaming.kafka.KafkaUtils$.createDirectStream(KafkaUtils.scala:484)
      4. org.apache.spark.streaming.kafka.KafkaUtils$.createDirectStream(KafkaUtils.scala:607)
      5. org.apache.spark.streaming.kafka.KafkaUtils.createDirectStream(KafkaUtils.scala)
      5 frames
    5. sparkstreamingtest
      test1.main
      1. sparkstreamingtest.test1.main(test1.java:64)
      1 frame