2.4. 将 Debezium 从版本 1.x 升级到 2.3.4

流程

1. 在 OpenShift 控制台中，查看 Kafka Connector YAML 来识别在 Debezium 2.3.4 中不再有效的连接器配置。详情请参阅 2023.Q2 发行注记。
2. 编辑配置，为在第 1 步中识别的属性添加 2.x 等效项，以便存在旧属性和新属性名称。将新属性的值设置为之前为旧属性指定的值。
3. 在 OpenShift 控制台中，停止 Kafka Connect 以安全停止连接器。
4. 在 OpenShift 控制台中，编辑 Kafka Connect 镜像 YAML 来引用连接器 zip 文件的 Debezium 2.3.4.Final 版本。
5. 在 OpenShift 控制台中，编辑 Kafka Connector YAML 以删除不再对连接器有效的配置选项。
6. 根据需要调整应用程序的存储依赖项，具体取决于代码中的存储模块实现依赖项。如需更多信息，请参阅 2023.Q2 发行注记中的 Debezium 存储的变化。
7. 重启 Kafka Connect 以启动连接器。重启连接器后，它会从升级前停止的时间点继续处理事件。在不修改升级前，更改连接器写入 Kafka 的事件记录。