17.4. 升级到 AMQ Streams 1.8
本节概述了将部署升级到使用 AMQ Streams 1.8 的步骤。
由 AMQ Streams 管理的 Kafka 集群的可用性不受升级操作的影响。
有关如何升级到该版本的信息，请参阅支持 AMQ Streams 特定版本的文档。
17.4.1. 升级 Kafka 代理和 ZooKeeper
这个步骤描述了如何在主机机器上升级 Kafka 代理和 ZooKeeper，以使用最新版本的 AMQ Streams。
先决条件
-
以
kafka用户身份登录 Red Hat Enterprise Linux。
流程
对于 AMQ Streams 集群中的每个 Kafka 代理，一次一个：
从 客户门户网站 下载 AMQ Streams 存档。
注意如有提示，登录到您的红帽帐户。
在命令行中，创建一个临时目录并提取
amq-streams-x.y.z-bin.zip文件的内容。mkdir /tmp/kafka unzip amq-streams-x.y.z-bin.zip -d /tmp/kafka
如果正在运行，停止 ZooKeeper 并在主机上运行的 Kafka 代理。
/opt/kafka/bin/zookeeper-server-stop.sh /opt/kafka/bin/kafka-server-stop.sh jcmd | grep zookeeper jcmd | grep kafka
从现有安装中删除
libs、bin和docs目录：rm -rf /opt/kafka/libs /opt/kafka/bin /opt/kafka/docs
从临时目录中复制
libs、bin和docs目录：cp -r /tmp/kafka/kafka_y.y-x.x.x/libs /opt/kafka/ cp -r /tmp/kafka/kafka_y.y-x.x.x/bin /opt/kafka/ cp -r /tmp/kafka/kafka_y.y-x.x.x/docs /opt/kafka/
删除临时目录。
rm -r /tmp/kafka
-
在文本编辑器中，打开代理属性文件，该文件通常存储在
/opt/kafka/config/目录中。 检查
inter.broker.protocol.version和log.message.format.version属性是否已设置为 当前版本 ：inter.broker.protocol.version=2.7 log.message.format.version=2.7
不要更改
inter.broker.protocol.version，确保代理可以在升级过程中继续相互通信。如果没有配置这些属性，请将它们与当前版本一起添加。
重启更新的 ZooKeeper 和 Kafka 代理：
/opt/kafka/bin/zookeeper-server-start.sh -daemon /opt/kafka/config/zookeeper.properties /opt/kafka/bin/kafka-server-start.sh -daemon /opt/kafka/config/server.properties
Kafka 代理和 Zookeeper 将开始使用最新 Kafka 版本的二进制文件。
-
验证重启的 Kafka 代理是否已捕获了以下分区副本。使用
kafka-topics.sh工具确保代理中包含的所有副本都重新同步。具体步骤请查看 列出和描述主题。 - 执行升级 Kafka 的步骤，如 第 17.5 节 “升级 Kafka” 所述。
