17.4.2. 升级 Kafka Connect
这个步骤描述了如何在主机机器中升级 Kafka Connect 集群。
Kafka Connect 是一个客户端应用程序，应该包含在您选择的用于升级客户端的策略中。如需更多信息，请参阅升级客户端的策略。
先决条件
-
以
kafka用户身份登录 Red Hat Enterprise Linux。 - Kafka Connect 尚未启动。
流程
对于 AMQ Streams 集群中的每个 Kafka 代理，一次一个：
从 客户门户网站 下载 AMQ Streams 存档。
注意如有提示，登录到您的红帽帐户。
在命令行中，创建一个临时目录并提取
amq-streams-x.y.z-bin.zip文件的内容。mkdir /tmp/kafka unzip amq-streams-x.y.z-bin.zip -d /tmp/kafka
如果正在运行，停止主机上运行的 Kafka 代理和 ZooKeeper。
/opt/kafka/bin/kafka-server-stop.sh /opt/kafka/bin/zookeeper-server-stop.sh
从现有安装中删除
libs、bin和docs目录：rm -rf /opt/kafka/libs /opt/kafka/bin /opt/kafka/docs
从临时目录中复制
libs、bin和docs目录：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/
删除临时目录。
rm -r /tmp/kafka
以独立或分布式模式启动 Kafka Connect。
要在独立模式下启动，请运行
connect-standalone.sh脚本。指定 Kafka Connect 独立配置文件以及 Kafka Connect 连接器的配置文件。su - kafka /opt/kafka/bin/connect-standalone.sh /opt/kafka/config/connect-standalone.properties connector1.properties [connector2.properties ...]
要在分布式模式下启动，使用所有 Kafka Connect 节点上的
/opt/kafka/config/connect-distributed.properties配置文件启动 Kafka Connect worker：su - kafka /opt/kafka/bin/connect-distributed.sh /opt/kafka/config/connect-distributed.properties
验证 Kafka Connect 是否正在运行：
在独立模式中：
jcmd | grep ConnectStandalone
在分布式模式中：
jcmd | grep ConnectDistributed
- 验证 Kafka Connect 是否正在按预期生成和使用数据。
