配置Debezium MySQL Connector

现在，我们需要为MSK Connect创建一个custom plugin(自定义插件)，custom plugin是JAR包的集合，里面包括connectors, transforms, converters等组件，MSK将在connect集群上安装这些插件。

本节，我们将从Debebium官网（ https://debezium.io/releases/ ）下载MySQL connector plugin，并将其打包上传到S3, 以备后面的步骤使用。

官网上目前最新的版本是1.8，将其下载到本地：

image-20211230225941731

下载下来是tar.gz格式。由于MSK Connect只能使用ZIP或JAR格式，所以需要将其先转为ZIP格式：

$ tar xzf debezium-connector-mysql-1.8.0.Final-plugin.tar.gz
$ cd debezium-connector-mysql
$ zip -9 ../debezium-connector-mysql-1.8.0.zip *
$ cd ..

最后将zip压缩包上传到S3上，并记录上传的路径：

$ aws s3 cp debezium-connector-mysql-1.8.0.zip s3://my-bucket/path/

image-20211231074025399