java.util.ConcurrentModificationException: KafkaConsumer is not safe for multi-threaded access

代码中并被没有重复使用数据,
网上说repartition,还没测过,但是这会引起shuffle,有没有什么好的办法
已邀请:

刘狗

赞同来自:

已解决。。一直认为是消费过的偏移量,主要是对偏移量没有处理好,包括过时的偏移量等,现在已解决。。

要回复问题请先登录注册


中国HBase技术社区微信公众号:
hbasegroup

欢迎加入HBase生态+Spark社区钉钉大群