spark streaming 消费 kafka 数据时报 Java .lang.IllegalStateException: No current assignment for partition
消费 kafka 数据时刚开始可以稳定跑一会,但是过不了几分钟就跑出此异常程序中断,java.lang.IllegalStateException: No current assignment for partition解决:是因为我在集群上跑着消费程序,本地也在用相同的消费代码测试,结果就出现了同一个 groupID 在同一时刻多次消费同一个 topic,引发 offset 记录问题。...
·
消费 kafka 数据时刚开始可以稳定跑一会,但是过不了几分钟就跑出此异常程序中断,java.lang.IllegalStateException: No current assignment for partition
解决:是因为我在集群上跑着消费程序,本地也在用相同的消费代码测试,结果就出现了同一个 groupID 在同一时刻多次消费同一个 topic,引发 offset 记录问题。
更多推荐
已为社区贡献5条内容
所有评论(0)