spark streaming kafka Couldn't find leader

問題描述： 使用spark streaming接受kafka數據（使用direct方式）報錯 Couldn't find leader offsets for Set([test,0], [test,1], [test,3])     Exception in thread "main" org.apache.spark.SparkException: java.nio.channels.Clos

>>阅读原文<<