19.5. 升级 Kafka 组件

在主机机器上升级 Kafka 组件以使用最新版本的 AMQ Streams。您可以使用 AMQ Streams 安装文件来升级以下组件：

先决条件

以 kafka 用户身份登录 Red Hat Enterprise Linux。
您已下载了安装文件。
您已在单独的主机上安装 Kafka 和其他 Kafka 组件。
更多信息请参阅第 3.1 节 “安装环境”。
您已升级了 Kafka 和 ZooKeeper。
如果 Kafka 组件在与 Kafka 和 ZooKeeper 相同的主机上运行，则在升级时还需要停止并启动 Kafka 和 ZooKeeper。

流程

对于运行 Kafka 组件实例的每个主机：

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

cp -r /tmp/kafka/kafka_<version>/libs /opt/kafka/
cp -r /tmp/kafka/kafka_<version>/bin /opt/kafka/

使用适当的脚本和属性文件启动 Kafka 组件。

以独立模式启动 Kafka 连接

/opt/kafka/bin/connect-standalone.sh \
/opt/kafka/config/connect-standalone.properties <connector1>.properties
[<connector2>.properties ...]

以分布式模式启动 Kafka 连接

/opt/kafka/bin/connect-distributed.sh \
/opt/kafka/config/connect-distributed.properties

以专用模式启动 MirrorMaker 2

/opt/kafka/bin/connect-mirror-maker.sh \
/opt/kafka/config/connect-mirror-maker.properties

启动 Kafka Bridge

su - kafka
./bin/kafka_bridge_run.sh \
--config-file=<path>/application.properties