spark streaming 整合kafka 报错 KafkaConsumer is not safe for multi-threaded access
问题描述spark streaming 使用 直连方式 读取kafka 数据，使用窗口时出现java.util.ConcurrentModificationException: KafkaConsumer is not safe for multi-threaded access报错信息如图：代码object testScala { def main(args: Array[String]): Unit = { val conf = new SparkConf() .se
