kafka重复消费问题

问题描述 采用kafka读取消息进行处理时，consumer会重复读取afka队列中的数据。web 问题缘由 kafka的consumer消费数据时首先会从broker里读取一批消息数据进行处理，处理完成后再提交offset。而咱们项目中的consumer消费能力比较低，致使取出的一批数据在session.timeout.ms时间内没有处理完成，自动提交offset失败，而后kafka会从新分配p

>>阅读原文<<