如何在Kafka-connect中升级我的Debezium插件版本



我目前正在运行Debezium 0.9.4,我想将其升级到最新的1.6版本。我只是下载jar文件并将它们保存到我的kafka-connectworker.properties文件中指定的插件目录中吗?从这里的文件来看,是什么意思

remove the old plugin files, install the 1.6.0.CR1 plugin files

什么是CR1插件文件?JAR文件在哪里?

Release 1.6.0.CR1(2021年6月24日(是版本的名称,根据文档,是的,您可以优雅地停止连接器,删除旧的JAR(从当前目录中(并复制新的JAR。祝你好运

将{/usr/local/share/kafka/plugins/debezium connector mysql/}的当前内容移动到{/usr/local/share/kaf ka/pluins}之外的备份文件夹中,并将解压缩的目录复制到插件路径中

你可能需要重新考虑,因为根据发布页面1.5是当前的稳定版本,看看他们下个月的发布周期,可能会得出1.6的最终稳定版本。

https://debezium.io/releases/

当您决定将其中一个连接器从任何早期版本升级到1.6.0.CR1时,请首先查看您正在使用的版本的迁移说明。优雅地停止正在运行的连接器,删除旧的插件文件,安装1.6.0.CR1插件文件,然后使用相同的配置重新启动连接器。重启后,1.6.0.CR1连接器将在上一个连接器中断的地方继续。正如人们所料,以前由旧连接器写入Kafka的所有更改事件都不会被修改

最新更新