15.4. 升级 Kafka Connect

这个步骤描述了如何在主机中升级 Kafka Connect 集群。

先决条件

流程

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

从 AMQ Streams 软件下载页面下载 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 目录：

rm -rf /opt/kafka/libs /opt/kafka/bin /opt/kafka/docs

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

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-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 是否按预期生成和使用数据。

其他资源