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