go - 容器重新启动后重播 Kafka 消息

Question

因此，作为消费者的一部分，我有一个长时间运行的过程，需要 5 分钟才能完成。我设置了以下值以避免由于超时问题而重新平衡。c.Consumer.MaxProcessingTime = 持续时间 c.Consumer.Group.Rebalance.Timeout = 持续时间 + 5*time.Second

我在 golang 中使用 Shopify sarama 库。我们有 3 个容器和 1 个分区（我们将很快增加）。我观察到一个问题，当容器重新启动时，所有 3 个容器都开始处理最后一条消息。