Kafka踩坑笔记 - SparkStreaming连接 Kafka出现KafkaConsumer is not safe for multi-threaded access错误
问题描述今天在使用 SparkStreaming消费kafka数据的时候, 出现了这个错误, 很莫名其妙去百度查了下, 发现这个错误是因为由于需要定时启动Kafka consumer拉取数据，第一次启动后，没有关掉线程。但Kafka consumer是非线程安全的，第二次消费数据时会报错：java.util.ConcurrentModificationException: KafkaCo...
