近段时间学习极客时间李玥老师的后端存储实战课时，看到一个很多意思的东西：用kafka存储点击流的数据，并重复处理。在以往的使用中，kafka只是一个消息传输的载体，消息被消费后就不能再次消费。新知识与印象相冲突，于是就有了本篇文章：kafka数据如何被重复消费。 前期理论了解 首先我先去官网 ...

场景： kafka先批量拉取消息，完了将拉下来的消息逐条消费，假如此次共拉取40条消息，但在处理第31条时，线程被停掉，就会导致已消费消息offet不会被提交，接下来已经被消费的30条记录还会被重复消费，这就是kafka重复消费的另一场景； 解决思路： 解决此类重复消费的方式：将能够唯一标识 ...

重复消费的原因 　　消息重复消费的根本原因都在于：已经消费了数据，但是offset没有成功提交。 　　其中很大一部分原因在于发生了再均衡。 　　　　1）消费者宕机、重启等。导致消息已经消费但是没有提交offset。 　　　　2）消费者使用自动提交offset，但当还没有提交的时候，有新 ...

在做分布式编译的时候，每一个worker都有一个consumer，适用的kafka+zookeep的配置都是默认的配置，在消息比较少的情况下，每一个consumer都能均匀得到互不相同的消息，但是当消息比较多的时候，这个时候consumer就有重复消费的情况。 如何排查这种问题呢？ 最 ...

先处理消费端的丢失数据和重复消费 这俩种情况都是 消息偏移offset的问题导致的，只是场景不同。 offset位移提交一般有俩种方式，自动位移提交和手动位移提交。用enable.auto.commit这个配置属性去控制 丢失消息一般是自动提交的问题，所以切换成手动位移提交就可以 ...

今天我司线上kafka消息代理出现错误日志，异常rebalance，而且平均间隔2到3分钟就会rebalance一次，分析日志发现比较严重。错误日志如下 08-09 11:01:11 131 pool-7-thread-3 ERROR [] - commit ...

https://www.cnblogs.com/756623607-zhang/p/10506909.html ...

原文链接：https://blog.csdn.net/z1941563559/java/article/details/88753938 问题描述：kafka的某些topic在消费完毕后一段时间，重启唯一消费者，offset会重置为最小offset重新消费，一直导致kafka消费的重复消费问题 ...