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

问题描述

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

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

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）