我正在使用golang和sarama客户机。Kafka版本是0.9，我计划升级。
我计划将sarama客户端升级到最新版本，并使用sarama集群而不是wvanbergen/kafka。我知道现在Kafka会得到补偿。
在apachekafka页面上，它说要从基于zk的存储迁移到kafka，需要执行以下操作：在用户配置中设置offset.storage=kafka和dual.commit.enabled=true。
在wvanbergen/kafka图书馆没有这样的财产，他们也没有计划添加它。
是否有人在生产系统上执行了从wvanbergen/kafka到sarama集群的类似升级，而没有dual.commit.enabled设置？如何将偏移量从zk迁移到kafka？