Red Hat Summit 红帽全球峰会支持控制台（Console）开发人员开始试用联系人

15.3. 升级 Kafka 代理和 ZooKeeper

此流程描述了如何在主机中升级 Kafka 代理和 ZooKeeper 以使用 AMQ Streams 的最新版本。

您可以更新您的文件，然后配置并重启所有 Kafka 代理以使用新的 inter-broker 协议版本。执行这些步骤后，数据会使用新的 inter-broker 协议版本在 Kafka 代理之间传输。

注意

从 Kafka 3.0.0 开始，消息格式版本值被假定为与 inter.broker.protocol.version 匹配，不需要设置。该值反映了使用的 Kafka 版本。

收到的消息仍然以较早的消息格式版本附加到消息日志中。

先决条件

  • 以 kafka 用户身份登录 Red Hat Enterprise Linux。

流程

对于 AMQ Streams 集群中的每个 Kafka 代理，一次一个：

  1. 从 AMQ Streams 软件下载页面 下载 AMQ Streams 存档。

    注意

    如有提示，登录到您的红帽帐户。

  2. 在命令行中，创建一个临时目录并提取 amq-streams-x.y.z-bin.zip 文件的内容。 

    mkdir /tmp/kafka
unzip amq-streams-x.y.z-bin.zip -d /tmp/kafka
    Copy to Clipboard Toggle word wrap

  3. 如果运行，停止 ZooKeeper 和主机上运行的 Kafka 代理。 

    /opt/kafka/bin/zookeeper-server-stop.sh
/opt/kafka/bin/kafka-server-stop.sh
jcmd | grep zookeeper
jcmd | grep kafka
    Copy to Clipboard Toggle word wrap

  4. 从现有安装中删除 libs 和 bin 目录： 

    rm -rf /opt/kafka/libs /opt/kafka/bin
    Copy to Clipboard Toggle word wrap

  5. 从临时目录中复制 libs 和 bin 目录： 

    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/
    Copy to Clipboard Toggle word wrap

  6. 删除临时目录。 

    rm -r /tmp/kafka
    Copy to Clipboard Toggle word wrap
  7. 在文本编辑器中，打开代理属性文件，通常存储在 /opt/kafka/config/ 目录中。

  8. 检查 inter.broker.protocol.version 和 log.message.format.version 属性是否已设置为当前版本： 

    inter.broker.protocol.version=3.0
log.message.format.version=3.0
    Copy to Clipboard Toggle word wrap

    将 inter.broker.protocol.version 保持不变，可确保代理可以在升级过程中继续相互通信。

    如果没有配置属性，请使用当前版本添加它们。

  9. 重启更新的 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
    Copy to Clipboard Toggle word wrap

    Kafka 代理和 Zookeeper 将开始使用最新 Kafka 版本的二进制文件。

  10. 验证重启的 Kafka 代理是否有分区副本。

    使用 kafka-topics.sh 工具来确保代理中包含的所有副本都重新同步。具体步骤请参阅 列出和描述主题。

    在后续步骤中，更新您的 Kafka 代理以使用新的 inter-broker 协议版本。

    一次更新每个代理。

    警告

    完成以下步骤后，无法降级 AMQ Streams。

  11. 在文本编辑器中，打开您要更新的 Kafka 代理的代理属性文件。代理属性文件通常存储在 /opt/kafka/config/ 目录中。

  12. 将 inter.broker.protocol.version 设置为 3.1。 

    inter.broker.protocol.version=3.1
    Copy to Clipboard Toggle word wrap

  13. 在命令行中停止您修改的 Kafka 代理： 

    /opt/kafka/bin/kafka-server-stop.sh
jcmd | grep kafka
    Copy to Clipboard Toggle word wrap

  14. 重启您修改的 Kafka 代理： 

    /opt/kafka/bin/kafka-server-start.sh -daemon /opt/kafka/config/server.properties
    Copy to Clipboard Toggle word wrap

  15. 验证重启的 Kafka 代理是否有分区副本。

    使用 kafka-topics.sh 工具来确保代理中包含的所有副本都重新同步。具体步骤请参阅 列出和描述主题。

返回顶部
Red Hat logoGithubredditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

通过我们的产品和服务，以及可以信赖的内容，帮助红帽用户创新并实现他们的目标。 了解我们当前的更新.

让开源更具包容性

红帽致力于替换我们的代码、文档和 Web 属性中存在问题的语言。欲了解更多详情，请参阅红帽博客.

關於紅帽

我们提供强化的解决方案，使企业能够更轻松地跨平台和环境（从核心数据中心到网络边缘）工作。

Theme

© 2025 Red Hat