红帽全球峰会17.5. 升级 Kafka 组件
在主机机器上升级 Kafka 组件以使用最新版本的 AMQ Streams。您可以使用 AMQ Streams 安装文件升级以下组件：
- Kafka Connect
- MirrorMaker
- Kafka Bridge （扩展 ZIP 文件）
先决条件
-
以
kafka用户身份登录到 Red Hat Enterprise Linux。 - 您已下载了 安装文件。
您已在单独的主机上安装 Kafka 和其他 Kafka 组件。
更多信息请参阅 第 3.1 节 “安装环境”。
如果 Kafka 组件与 Kafka 和 ZooKeeper 在同一个主机上运行，则升级时还需要停止和启动 Kafka 和 ZooKeeper。
流程
对于运行 Kafka 组件的实例的每个主机：
从 AMQ Streams 软件下载页面，下载 AMQ Streams 或 Kafka Bridge 安装文件。
注意出现提示时，登录到您的红帽帐户。
在命令行中，创建一个临时目录并提取
amq-streams-<version>-bin.zip文件的内容。mkdir /tmp/kafka unzip amq-streams-<version>-bin.zip -d /tmp/kafka
对于 Kafka Bridge，解压
amq-streams-<version>-bridge-bin.zip文件。- 如果正在运行，停止主机上运行的 Kafka 组件。
从现有安装中删除
libs和bin目录：rm -rf /opt/kafka/libs /opt/kafka/bin
从临时目录中复制
libs和bin目录：cp -r /tmp/kafka/kafka_<version>/libs /opt/kafka/ cp -r /tmp/kafka/kafka_<version>/bin /opt/kafka/
-
如果需要，更新
config目录中的配置文件，以反映新版本的任何更改。 删除临时目录。
rm -r /tmp/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验证 Kafka 组件是否正在运行，并按预期生成或消耗数据。
在独立模式中验证 Kafka 连接正在运行
jcmd | grep ConnectStandalone
在分布式模式中验证 Kafka 连接正在运行
jcmd | grep ConnectDistributed
在专用模式中验证 MirrorMaker 2 正在运行
jcmd | grep mirrorMaker
通过检查日志来验证 Kafka Bridge 是否正在运行
HTTP-Kafka Bridge started and listening on port 8080 HTTP-Kafka Bridge bootstrap servers localhost:9092
