17.5. 升级 Kafka

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

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

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

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

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

警告

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

先决条件

流程

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

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

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

/opt/kafka/bin/kafka-server-stop.sh
jcmd | grep kafka

重启您修改的 Kafka 代理：

/opt/kafka/bin/kafka-server-start.sh -daemon /opt/kafka/config/server.properties

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