你也新年好,你看下这篇文章中的,手动控制偏移量的代码片段。
先以文中的例子做测试,如果不行,贴代码出来。
https://www.orchome.com/451
你好大哥,我还有个问题,就是我用kafka客户端消费时,我是手动提交偏移量的,把主题上的数据全部消费完,我重启客户端,让它再次消费,发现消费到上一次提交过offset的数据(起码我在代码里是提交offset了的),多试几次也是一样。这是咋回事呢?
对应的。给你一篇文章,里面有详细介绍。
https://www.orchome.com/23
跟情况来指定是否连续,默认连续。
比如电话号码,是保留最新的电话,还是变更的整个过程都需要。看你的需求了。