我正在使用 Golang 和 Sarama 客户端。Kafka 版本是 0.9，我计划升级。
我计划将 sarama 客户端升级到最新版本并使用 sarama-cluster 而不是 wvanbergen/kafka。我看到偏移量现在将提交给 kafka。
在 Apache Kafka 页面上，它说要从基于 zk 的存储迁移到 kafka，您需要执行以下操作：在您的使用者配置中设置 offsets.storage=kafka 和 dual.commit.enabled=true。
wvanbergen/kafka 库中没有这样的属性，他们也没有计划添加它。
有没有人在生产系统上没有 dual.commit.enabled 设置的情况下从 wvanbergen/kafka 到 sarama-cluster 进行了类似的升级？你是如何将偏移量从 zk 迁移到 kafka 的？