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

Question

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

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