搜索

17.5. 升级 Kafka

download PDF

升级二进制文件以使用最新版本的 AMQ Streams 后,您可以升级代理和客户端以使用更高版本的 Kafka。

请小心遵循正确的顺序执行这些步骤:

在 Kafka 升级后,如果需要,您可以升级 Kafka 用户以使用增量合作重新平衡协议:

17.5.1. 升级 Kafka 代理以使用新的代理版本

手动配置并重启所有 Kafka 代理,以使用新的 Inter-broker 协议版本。执行这些步骤后,会使用新的 Inter-broker 协议版本在 Kafka 代理之间传输数据。

收到的消息仍附加到之前消息格式版本中的消息日志中。

警告

完成此步骤后,无法降级 AMQ Streams。

先决条件

流程

对于 AMQ Streams 集群中的每个 Kafka 代理,一次一个:

  1. 在文本编辑器中,打开您要更新的 Kafka 代理的代理属性文件。代理属性文件通常存储在 /opt/kafka/config/ 目录中。
  2. inter.broker.protocol.version 设置为 2.8

    inter.broker.protocol.version=2.8
  3. 在命令行中停止您修改的 Kafka 代理:

    /opt/kafka/bin/kafka-server-stop.sh
    jcmd | grep kafka
  4. 重启您修改的 Kafka 代理:

    /opt/kafka/bin/kafka-server-start.sh -daemon /opt/kafka/config/server.properties
  5. 验证重启的 Kafka 代理是否已捕获了以下分区副本。使用 kafka-topics.sh 工具确保代理中包含的所有副本都重新同步。具体步骤请查看 列出和描述主题
Red Hat logoGithubRedditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

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

让开源更具包容性

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

關於紅帽

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

© 2024 Red Hat, Inc.