Kafka 消费者接收到重复消息

学习Golang要努力，但是不要急！今天的这篇文章《Kafka 消费者接收到重复消息》将会介绍到等等知识点，如果你想深入学习Golang，可以关注我！我会持续更新相关文章的，希望对大家都能有所帮助！

我有一个包含 30 个实例的 golang 服务。有一个具有 3 个分区的主题和一个监听消息的消费者组。我们面临的问题是，每条消息都被同一个消费者一次又一次地获取，间隔为 24-30 小时。 我已经确认消息被推送到主题一次，甚至每次消息都是相同的，但消息以不同的时间间隔被拾取，例如：

• 2021 年 6 月 2 日 12:59:29.555
• 2021 年 6 月 3 日 20:33:11.438
• 2021 年 6 月 5 日 12:08:40.710
• 2021 年 6 月 6 日 12:34:39.188

有人可以帮忙解决这个问题吗？谢谢

正确答案

1. 您不需要从 3 个分区使用 30 个实例。因为分区不在消费者实例之间共享。因此，如果您的主题有 3 个分区，则您的消费者实例的最大数量应为 3。

2. 如果您的消费者在消费后未提交读取消息，则可能会发生重新消费。查看消费者提交间隔以及启用或禁用的自动提交。如果你消费的消息没有提交，那么消费者重新平衡后，这些消息就可以被重新消费。

好了，本文到此结束，带大家了解了《Kafka 消费者接收到重复消息》，希望本文对你有所帮助！关注golang学习网公众号，给大家分享更多Golang知识！