本文主要是介绍制作 MSK Connect 的 Confluent Avro Converter + Debezium MySQL Connector 插件包,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!
MSK Connect 的插件包需要将各种插件的 Jar 包及其依赖包放到一起,打成 Zip 包,上传到 S3,然后在MSK Console 上创建插件时指定好 Zip 位置即可。为了便于维护,我们不建议将各种插件的 Jar 包混在一起放入同一个文件内,最好还是按插件原来的名称单独创建文件夹,单独放置各自的 Jar 包。我们以 Debezium MySQL Connector 和 Confluent Avro Converter 这两个插件为例:
组件 | 版本 |
---|---|
Confluent Avro Converter | 7.2.2 |
Debezium MySQL Source Connector | 2.2.0 |
直接下载
打开 https://www.confluent.io/hub/ 搜索 “Debezium MySQL CDC Source Connector”,点击找到的项,进入 “Debezium MySQL CDC Source Connector” 页面,点击左下角的 “Download previous versions” 链接,选择 2.2.0 版本下载。解压下载后的包
这篇关于制作 MSK Connect 的 Confluent Avro Converter + Debezium MySQL Connector 插件包的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!