当前位置： 首页闲谈正文 例如kafka的offset可能是消费者批量处理后才提交到zk，重启后再消费时就可能会收到重复 消息，需要消费者在处理消息时做幂等性设计，即先判断是否消费过，把已消费的放到本地缓 存或者redis中，每次消费时先做个判断即可。 蔡俊伟 打赏 链接
