- 链接地址:https://blog.csdn.net/a904364908/article/details/104437450
- 链接标题:sparkstreaming ConcurrentModificationException: KafkaConsumer is not safe for multi-threaded access_concurrentmodificationexception:kafkaconsumer is n-CSDN博客
- 所属网站:blog.csdn.net
- 被收藏次数:3066
文章浏览阅读1k次。最近在测试sparkstreaming的时候发现了一个问题,记录一下环境 spark 2.x, kafka_0.10.x示例代码:val ssc: StreamingContext = new StreamingContext(sparkSession.sparkContext,Seconds(5)) val kafkaBrokers:String = "hadoop01:9092..._concurrentmodificationexception:kafkaconsumer is not safe for mu
版权声明:本文发布于特牛网址导航 内容均来源于互联网 如有侵权联系删除