[jira] [Created] (SPARK-18983) Couldn't find leader offsets exception when the one of kafka cluster brokers is down

["kraken (JIRA)" <ji...@apache.org>]

kraken created SPARK-18983:
------------------------------

             Summary: Couldn't find leader offsets exception when the one of kafka cluster brokers is down
                 Key: SPARK-18983
                 URL: https://issues.apache.org/jira/browse/SPARK-18983
             Project: Spark
          Issue Type: Bug
            Reporter: kraken
            Priority: Critical


Hello,i got a trouble today

when the company's PE restarts the one of kafka cluster broker,my spark job run failed.

Exception in thread "main" org.apache.spark.SparkException: get earliest leader offsets failed: ArrayBuffer(org.apache.spark.SparkException: Couldn't find leaders for Set

I use the low level type to consume  kafka log, i know that high level can be aware of the lead changes, but how can i do that by use low level?



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@spark.apache.org
For additional commands, e-mail: issues-help@spark.apache.org