apache-kafka-connect - How do I upgrade my Debezium plug-in version in Kafka connect?

Question

I am currently running Debezium 0.9.4 and I want to upgrade it to the latest version 1.6. Do I simply download the jar files and save them to the plug-in directory specified in my kafka-connect worker.properties file? From the document here, what do they mean by

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

What is the CR1 plug-in files? Where are the JAR files?

标签： apache-kafka-connectdebezium

Answer 1

Release 1.6.0.CR1 (June 24th, 2021) is the name of release and according to the docs, yes, you stop the connector gracefully, remove the old JARs (from the directory that you currently have) and copy the new ones. Good luck!

Move the current content of {/usr/local/share/kafka/plugins/debezium-connector-mysql/} to a backup folder outside of {/usr/local/share/kafka/plugins} and copy the unziped directory into the plugin path

You might want to reconsider as according to the release page 1.5 is the current stable release , looking on their release cycle next month probably would came out 1.6 final as stable version.

https://debezium.io/releases/

When you decide to upgrade one of these connectors to 1.6.0.CR1 from any earlier versions, first check the migration notes for the version you’re using. Gracefully stop the running connector, remove the old plugin files, install the 1.6.0.CR1 plugin files, and restart the connector using the same configuration. Upon restart, the 1.6.0.CR1 connectors will continue where the previous connector left off. As one might expect, all change events previously written to Kafka by the old connector will not be modified