go - Confluent go kafka 库从重启时最早的偏移量开始

Question

我们目前为我们的经纪人使用 Kafka 0.8.2。我们使用 .Poll() 方法来抓取消息并在收集到 1000 条消息后提交。我们可以使用这个库很好地从集群中消费，我可以看到偏移量通过手动提交调用存储在 __consumer_offsets 主题中。但是，当消费者重新启动时，它不会使用存储的偏移量。相反，它从最早的偏移量重新开始（我有 auto.offset.reset=earliest）。我是否需要做一些特定的事情来强制 Kafka 使用这些偏移量而不是在 Zookeeper 中查找，还是应该让消费者来处理？有没有办法强制消费者将偏移量写入 Zookeeper 而不是 __consumer_offsets 主题？

标签： goapache-kafkaconfluent-platform