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 代理,一次一个:

  1. 客户门户网站 下载 AMQ Streams 存档。

    注意

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

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

    mkdir /tmp/kafka
    unzip amq-streams-x.y.z-bin.zip -d /tmp/kafka
  3. 如果正在运行,停止 ZooKeeper 并在主机上运行的 Kafka 代理。

    /opt/kafka/bin/zookeeper-server-stop.sh
    /opt/kafka/bin/kafka-server-stop.sh
    jcmd | grep zookeeper
    jcmd | grep kafka
  4. 从现有安装中删除 libsbindocs 目录:

    rm -rf /opt/kafka/libs /opt/kafka/bin /opt/kafka/docs
  5. 从临时目录中复制 libsbindocs 目录:

    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/
  6. 删除临时目录。

    rm -r /tmp/kafka
  7. 在文本编辑器中,打开代理属性文件,该文件通常存储在 /opt/kafka/config/ 目录中。
  8. 检查 inter.broker.protocol.versionlog.message.format.version 属性是否已设置为 当前版本

    inter.broker.protocol.version=2.7
    log.message.format.version=2.7

    不要更改 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

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

  10. 验证重启的 Kafka 代理是否已捕获了以下分区副本。使用 kafka-topics.sh 工具确保代理中包含的所有副本都重新同步。具体步骤请查看 列出和描述主题
  11. 执行升级 Kafka 的步骤,如 第 17.5 节 “升级 Kafka” 所述。
Red Hat logoGithubRedditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

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

让开源更具包容性

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

關於紅帽

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

© 2024 Red Hat, Inc.