特牛网址导航

sparkstreaming ConcurrentModificationException: KafkaConsumer is not safe for multi-threaded access_concurrentmodificationexception:kafkaconsumer is n-CSDN博客

网友收藏
  • 链接地址: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