17.5.3. 将客户端应用程序升级到新的 Kafka 版本
此流程描述了将客户端应用程序升级到 AMQ Streams 1.8 使用的 Kafka 版本的一种可能的方法。
该流程基于"每个主题消费者的"方法，其中概述了 用于升级客户端的策略 中概述的向下转换方法。
客户端应用程序包括制作者、使用者、Kafka Connect、Kafka Streams 应用程序和 MirrorMaker。
先决条件
- 您已更新了 ZooKeeper 二进制文件，并将所有 Kafka 代理升级到 AMQ Streams 1.8
- 您已将 Kafka 代理配置为使用新的 Inter-broker 协议版本。
-
以
kafka用户身份登录 Red Hat Enterprise Linux。
流程
对于每个主题：
在命令行中，将
message.format.version配置选项设置为2.7。bin/kafka-configs.sh --bootstrap-server <BrokerAddress> --entity-type topics --entity-name <TopicName> --alter --add-config message.format.version=2.7
- 升级该主题的所有消费者和生产者。
- 另外，要升级使用者和 Kafka Streams 应用程序以使用 增量合作重新平衡 协议（在 Kafka 2.4.0 中添加），请参阅 第 17.5.5 节 “升级消费者和 Kafka Streams 应用程序以合作重新平衡”。
- 验证升级的应用是否正常工作。
将主题的
message.format.version配置选项改为2.8。bin/kafka-configs.sh --bootstrap-server <BrokerAddress> --entity-type topics --entity-name <TopicName> --alter --add-config message.format.version=2.8
其它资源
