将数据从kafka复制到mysql，无法使用DOcker和Debezium连接到JDBCSinkConnector

Question

大家好，我正在使用debezium捕获Mongo中的更改，并将它们推送到mysql中。我正在使用以下链接https://github.com/debezium/debezium-examples/tree/master/unwrap-mongodb-smt我正在把postgres数据库替换为mysql数据库，但我无法这样做。

这是我修改后的jdbc-sink.json，我使用mysql url连接。

{
    "name" : "jdbc-sink",
    "config" : {
        "connector.class":"io.confluent.connect.jdbc.JdbcSinkConnector",
        "tasks.max" : "1",
        "topics" : "customers",
        "connection.url" : "jdbc:mysql://localhost:3306/inventorydb?user=user&password=password",
        "auto.create" : "true",
        "auto.evolve" : "true",
        "insert.mode" : "upsert",
        "delete.enabled": "true",
        "pk.fields" : "id",
        "pk.mode": "record_key",
        "transforms": "mongoflatten",
        "transforms.mongoflatten.type" : "io.debezium.connector.mongodb.transforms.ExtractNewDocumentState",
        "transforms.mongoflatten.drop.tombstones": "false"
    }
}

但我在运行时遇到以下错误

curl -i -X POST -H "Accept:application/json" -H  "Content-Type:application/json" http://localhost:8083/connectors/ -d @jdbc-sink.json

HTTP/1.1 500内部服务器错误日期：周三，06十一月2019 08:13:39格林尼治标准时间内容类型：应用程序/json内容长度： 3404服务器：码头（9.4.18. v20190429）

{“error_code”：500，“message”：“找不到任何实现连接器的类，以及名称与io.confluent.connect.jdbc.JdbcSinkConnector匹配的类，可用的连接器有：PluginDesc”{klass=class io.debezium.connector.mongodb.MongoDbConnector，name='io.debezium.connector.mongodb.MongoDbConnector'，version='1.0.0-SNAPSHOT'，encodedVersion=1.0.0-SNAPSHOT，type=source，typeName='source'，location='file:/kafka/connect/debezium connector mongodb/'}，PluginDesc{klass=class io.debezium.connector.mysql.MySqlConnector，name='io.debezium.connector.mysql.MySqlConnector'，version='1.0.0-SNAPSHOT'，encodedVersion=1.0.0-SNAPSHOT，type=source，typeName='source'，location='file:/kafka/connect/debezium connector mysql/'，PluginDesc{klass=class io.debezium.connector.oracle.OracleConnector，name='io.debezium.connector.oracle.OracleConnector'，version='1.0.0-SNAPSHOT'，encodedVersion=1.0.0-SNAPSHOT，type=source，typeName='source'，location='file:/kafka/connect/debezium connector-oracle/'，PluginDesc{klass=class io.debezium.connector.postgresql.PostgresConnector，name='io.debezium.connector.postgresql.PostgresConnector'，version='1.0.0-SNAPSHOT'，encodedVersion=1.0.0-SNAPSHOT，type=source，typeName='source'，location='file:/kafka/connect/debezium connector-postgres，PluginDesc{klass=class io.debezium.connector.sqlserver.SqlServerConnector，name='io.debezium.connector.sqlserver.SqlServerConnector'，version='1.0.0-SNAPSHOT'，encodedVersion=1.0.0-SNAPSHOT，type=source，typeName='source'，location='file:/kafka/connect/debezium connector sqlserver/'，PluginDesc{klass=class org.apache.kafka.connect.file.FileStreamSinkConnector，name='org.apache.kafka.connect.file.FileStreamSinkConnector'，version='2.3.0'，encodedVersion=2.3.0，type=sink，typeName='sink'，location='classpath'}，PluginDesc{klass=class org.apache.kafka.connect.file.FileStreamSourceConnector，name='org.apache.kafka.connect.file.FileStreamSourceConnector'，version='2.3.0'，encodedVersion=2.3.0，type=source，typeName='source'，location='classpath'，PluginDesc{klass=class org.apache.kafka.connect.tools.MockConnector，name='org.apache.kafka.connect.tools.MockConnector'，version='2.3.0'，encodedVersion=2.3.0，type=connector，typeName='connector'，location='classpath'}，PluginDesc{klass=class org.apache.kafka.connect.tools.MockSinkConnector，name='org.apache.kafka.connect.tools.MockSinkConnector'，version='2.3.0'，encodedVersion=2.3.0，type=sink，typeName='sink'，location='classpath'}，PluginDesc{klass=class org.apache.kafka.connect.tools.MockSourceConnector，name='org.apache.kafka.connect.tools.MockSourceConnector'，version='2.3.0'，encodedVersion=2.3.0，type=source，typeName='source'，location='classpath'}，PluginDesc{klass=class org.apache.kafka.connect.tools.SchemaSourceConnector，name='org.apache.kafka.connect.tools.SchemaSourceConnector'，version='2.3.0'，encodedVersion=2.3.0，type=source，typeName='source'，location='classpath'}，PluginDesc{klass=class org.apache.kafka.connect.tools.VerifiableSinkConnector，name='org.apache.kafka.connect.tools.VerifiableSinkConnector'，version='2.3.0'，encodedVersion=2.3.0，type=source，typeName='source'，location='classpath'}，PluginDesc{klass=class org.apache.kafka.connect.tools.VerifiableSourceConnector，name='org.apache.kafka.connect.tools.VerifiableSourceConnector'，version='2.3.0'，encodedVersion=2.3.0，type=source，typeName='source'，location='classpath'}

我知道有些人找不到io。汇合的。连接jdbc。JdbcSinkConnector，但是我应该如何/以及应该在哪里保存这样一个jar呢。

谢啦

Answer 1

使用以下命令下载JAR，并将其保存在插件目录中：

curl -sO https://packages.confluent.io/maven/io/confluent/kafka-connect-jdbc/10.0.0/kafka-connect-jdbc-10.0.0.jar

Answer 2

您还没有在Kafka Connect中提供接收器连接器，请参阅命令docker-comush up--build-d用于开始使用JDBC接收器连接器构建新的连接映像https://github.com/debezium/debezium-examples/blob/master/unwrap-mongodb-smt/debezium-jdbc/Dockerfile#L10