3.4. 将 Debezium 从版本 1.x 升级到 2.1.4

当前的 Debezium 版本包括在从早期版本升级时遵循特定步骤的更改。如需更多信息，请参阅中断更改列表和升级过程。

Debezium 2.1.4 是新 Debezium 主版本的第一个红帽发行版本。Debezium 2.1.4 中的一些更改与早期版本的 Debezium 不兼容。因此，要保留数据并确保当您从 Debezium 1.x 版本升级到 2.1.4 时继续操作，您必须在升级过程中完成一些手动步骤。

一个显著的变化是一些连接器参数的名称已更改。要容纳这些更改，请查看配置属性更新，并记录连接器配置中存在的属性。在升级前，编辑每个 Debezium 连接器的配置，以添加任何更改的属性的新名称。在升级前，请编辑任何 1.x 连接器实例的配置，以便存在旧的和新属性名称。升级后，您可以删除旧的配置选项。

先决条件

Debezium 现在与 Kafka 版本兼容，最多 3.3.1。这是 AMQ Streams 2.3 中的默认 Kafka 版本。
需要 Java 11 运行时，在升级前必须可用。AMQ Streams 2.3 支持 Java 11。在开发新应用程序时使用 Java 11。Java 11 启用最新的语言更新，如新的 String API 和 predicate 支持的变化，同时从 Java 性能改进中受益。AMQ Streams 2.3 不再支持 Java 8。
在明明更改列表中检查向后兼容的更改。
验证您的环境是否符合 Debezium 2.1.4 支持的配置。

流程

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

返回顶部