您好，我正在将 kafka 升级到 .9，并将 kafka 消费者升级到 .9 发布的新 Java 消费者。 升级时，我使用现有主题，步骤只是停止 .8 kafka 并启动指向相同 log.dirs 的 .9 kafka，在消费者端，我使用相同的组名和主题名，但新消费者正在从主题中的起始位置再次使用消息。我已经在 0.8 中提交了它们。 我正在添加 auto.offset.reset = early。
知道为什么会这样，或者我们需要首先使用 .8 消费者消费所有消息，然后让延迟变为 0。 谢谢 晴天
【问题讨论】：
标签： apache-kafka kafka-consumer-api
虽然 0.8 个消费者将偏移量存储在 Zookeeper 中，但 0.9 个消费者将它们存储在特定的 Kafka 主题中。因此，0.9 消费者通常不会看到 0.8 消费者存储的任何偏移量，因此将从头开始消费。有一个FAQ 可能有助于迁移偏移量。引用：
1) 升级您的代理并设置 dual.commit.enabled=false 和 offsets.storage=zookeeper（仅向 Zookeeper 提交偏移量）。
2) 设置 dual.commit.enabled=true 和 offsets.storage=kafka 并重新启动（向 Zookeeper 和 Kafka 提交偏移量）。
3) 设置 dual.commit.enabled=false 和 offsets.storage=kafka 并重新启动（仅将偏移量提交到 Kafka）。
（没试过，只是引用。）
【讨论】：