解決KafkaConsumer多線程接入不安全問題（spark streaming 消費kafka）

使用場景： 設置並行度參數spark.streaming.concurrentJobs >1 時候，使用spark streaming消費kafkagit 異常信息： There may be two or more tasks in one executor will use the same kafka consumer at the same time, then it will throw

>>阅读原文<<