kafka9重复消费问题解决

kafka9重复消费问题解决java 背景：以前用的kafka客户端版本是0.8，近期升级了kafka客户端的版本，写了新的消费者和生产者的代码，在本地测试没有问题，能够正常消费与生产。但最近的项目中使用了新版的代码，当数据量较大时会出现重复消费的问题。现将问题的排除与解决过程记录下来，避免再次踩坑。apache 问题发现：因为ConsumerRecord对象能够获取到当前消息的分区与偏移量，故在

>>阅读原文<<