使用 Shopify/sarama 重新启动程序时从 kafka 获取最新偏移量

如何解决使用 Shopify/sarama 重新启动程序时从 kafka 获取最新偏移量

对不起，我有一个关于 kafka 使用 Shopify/Sarama 的问题。

1. 我必须实现 func ConsumeClaim 并在内部循环以获取消息。 ConsumeClaim 在 goroutine 中被调用，每个分区都有自己的 goroutine。如果我消费的主题有 5 个分区，那么它将生成 5 个 goroutine 。 -> 我可以只做 3 个，而不是 5 个 goroutine 而不改变分区吗？ （使用缓冲区等...）
2. 当我重新启动程序时，它会在我停止程序之前从第一个偏移量而不是从当前偏移量开始。那么，如何在停止之前从最新的偏移量中获取消息？