error registering a debezium connector to kafka connect

Hello good afternoon

It’s great to have a platform to answer questions from the community, congratulations!

I want to talk about an error that I have regarding kafka connect when wanting to start a debezium connector

I have the kafka and zookepeer services active on a centos7 minimal operating system, when I want to start kafka connect in standalone mode with this command

bin/connect-standalone.sh config/connect-standalone.properties config/connector1.properties

when executing it I get the following error

[2021-02-04 13:08:17,433] INFO Kafka Connect started (org.apache.kafka.connect.runtime.Connect:55)
[2021-02-04 13:08:17,434] ERROR Failed to create job for config/connector1.properties (org.apache.kafka.connect.cli.ConnectStandalone:102)
[2021-02-04 13:08:17,435] ERROR Stopping after connector error (org.apache.kafka.connect.cli.ConnectStandalone:113)
java.util.concurrent.ExecutionException: org.apache.kafka.connect.errors.ConnectException: Failed to find any class that implements Connector and which name matches io.debezium.connector.mysql.mysqlconnector, available connectors are: PluginDesc{klass=class org.apache.kafka.connect.file.FileStreamSinkConnector, name='org.apache.kafka.connect.file.FileStreamSinkConnector', version='2.0.0.3.1.4.0-315', encodedVersion=2.0.0.3.1.4.0-315, type=sink, typeName='sink', location='classpath'}, PluginDesc{klass=class org.apache.kafka.connect.file.FileStreamSourceConnector, name='org.apache.kafka.connect.file.FileStreamSourceConnector', version='2.0.0.3.1.4.0-315', encodedVersion=2.0.0.3.1.4.0-315, type=source, typeName='source', location='classpath'}, PluginDesc{klass=class org.apache.kafka.connect.tools.MockConnector, name='org.apache.kafka.connect.tools.MockConnector', version='2.0.0.3.1.4.0-315', encodedVersion=2.0.0.3.1.4.0-315, type=connector, typeName='connector', location='classpath'}, PluginDesc{klass=class org.apache.kafka.connect.tools.MockSinkConnector, name='org.apache.kafka.connect.tools.MockSinkConnector', version='2.0.0.3.1.4.0-315', encodedVersion=2.0.0.3.1.4.0-315, type=sink, typeName='sink', location='classpath'}, PluginDesc{klass=class org.apache.kafka.connect.tools.MockSourceConnector, name='org.apache.kafka.connect.tools.MockSourceConnector', version='2.0.0.3.1.4.0-315', encodedVersion=2.0.0.3.1.4.0-315, type=source, typeName='source', location='classpath'}, PluginDesc{klass=class org.apache.kafka.connect.tools.SchemaSourceConnector, name='org.apache.kafka.connect.tools.SchemaSourceConnector', version='2.0.0.3.1.4.0-315', encodedVersion=2.0.0.3.1.4.0-315, type=source, typeName='source', location='classpath'}, PluginDesc{klass=class org.apache.kafka.connect.tools.VerifiableSinkConnector, name='org.apache.kafka.connect.tools.VerifiableSinkConnector', version='2.0.0.3.1.4.0-315', encodedVersion=2.0.0.3.1.4.0-315, type=source, typeName='source', location='classpath'}, PluginDesc{klass=class org.apache.kafka.connect.tools.VerifiableSourceConnector, name='org.apache.kafka.connect.tools.VerifiableSourceConnector', version='2.0.0.3.1.4.0-315', encodedVersion=2.0.0.3.1.4.0-315, type=source, typeName='source', location='classpath'}
        at org.apache.kafka.connect.util.ConvertingFutureCallback.result(ConvertingFutureCallback.java:79)
        at org.apache.kafka.connect.util.ConvertingFutureCallback.get(ConvertingFutureCallback.java:66)
        at org.apache.kafka.connect.cli.ConnectStandalone.main(ConnectStandalone.java:110)
Caused by: org.apache.kafka.connect.errors.ConnectException: Failed to find any class that implements Connector and which name matches io.debezium.connector.mysql.mysqlconnector, available connectors are: PluginDesc{klass=class org.apache.kafka.connect.file.FileStreamSinkConnector, name='org.apache.kafka.connect.file.FileStreamSinkConnector', version='2.0.0.3.1.4.0-315', encodedVersion=2.0.0.3.1.4.0-315, type=sink, typeName='sink', location='classpath'}, PluginDesc{klass=class org.apache.kafka.connect.file.FileStreamSourceConnector, name='org.apache.kafka.connect.file.FileStreamSourceConnector', version='2.0.0.3.1.4.0-315', encodedVersion=2.0.0.3.1.4.0-315, type=source, typeName='source', location='classpath'}, PluginDesc{klass=class org.apache.kafka.connect.tools.MockConnector, name='org.apache.kafka.connect.tools.MockConnector', version='2.0.0.3.1.4.0-315', encodedVersion=2.0.0.3.1.4.0-315, type=connector, typeName='connector', location='classpath'}, PluginDesc{klass=class org.apache.kafka.connect.tools.MockSinkConnector, name='org.apache.kafka.connect.tools.MockSinkConnector', version='2.0.0.3.1.4.0-315', encodedVersion=2.0.0.3.1.4.0-315, type=sink, typeName='sink', location='classpath'}, PluginDesc{klass=class org.apache.kafka.connect.tools.MockSourceConnector, name='org.apache.kafka.connect.tools.MockSourceConnector', version='2.0.0.3.1.4.0-315', encodedVersion=2.0.0.3.1.4.0-315, type=source, typeName='source', location='classpath'}, PluginDesc{klass=class org.apache.kafka.connect.tools.SchemaSourceConnector, name='org.apache.kafka.connect.tools.SchemaSourceConnector', version='2.0.0.3.1.4.0-315', encodedVersion=2.0.0.3.1.4.0-315, type=source, typeName='source', location='classpath'}, PluginDesc{klass=class org.apache.kafka.connect.tools.VerifiableSinkConnector, name='org.apache.kafka.connect.tools.VerifiableSinkConnector', version='2.0.0.3.1.4.0-315', encodedVersion=2.0.0.3.1.4.0-315, type=source, typeName='source', location='classpath'}, PluginDesc{klass=class org.apache.kafka.connect.tools.VerifiableSourceConnector, name='org.apache.kafka.connect.tools.VerifiableSourceConnector', version='2.0.0.3.1.4.0-315', encodedVersion=2.0.0.3.1.4.0-315, type=source, typeName='source', location='classpath'}
        at org.apache.kafka.connect.runtime.isolation.Plugins.newConnector(Plugins.java:179)
        at org.apache.kafka.connect.runtime.AbstractHerder.getConnector(AbstractHerder.java:374)
        at org.apache.kafka.connect.runtime.AbstractHerder.validateConnectorConfig(AbstractHerder.java:253)
        at org.apache.kafka.connect.runtime.standalone.StandaloneHerder.putConnectorConfig(StandaloneHerder.java:189)
        at org.apache.kafka.connect.cli.ConnectStandalone.main(ConnectStandalone.java:107)
[2021-02-04 13:08:17,436] INFO Kafka Connect stopping (org.apache.kafka.connect.runtime.Connect:65)
[2021-02-04 13:08:17,436] INFO Stopping REST server (org.apache.kafka.connect.runtime.rest.RestServer:223)
[2021-02-04 13:08:17,441] INFO Stopped http_8083@48c35007{HTTP/1.1,[http/1.1]}{0.0.0.0:8083} (org.eclipse.jetty.server.AbstractConnector:341)
[2021-02-04 13:08:17,442] INFO node0 Stopped scavenging (org.eclipse.jetty.server.session:167)
[2021-02-04 13:08:17,449] INFO Stopped o.e.j.s.ServletContextHandler@6869a3b3{/,null,UNAVAILABLE} (org.eclipse.jetty.server.handler.ContextHandler:1045)
[2021-02-04 13:08:17,451] INFO REST server stopped (org.apache.kafka.connect.runtime.rest.RestServer:241)
[2021-02-04 13:08:17,451] INFO Herder stopping (org.apache.kafka.connect.runtime.standalone.StandaloneHerder:95)
[2021-02-04 13:08:17,451] INFO Worker stopping (org.apache.kafka.connect.runtime.Worker:184)
[2021-02-04 13:08:17,451] INFO Stopped FileOffsetBackingStore (org.apache.kafka.connect.storage.FileOffsetBackingStore:67)
[2021-02-04 13:08:17,452] INFO Worker stopped (org.apache.kafka.connect.runtime.Worker:205)
[2021-02-04 13:08:17,453] INFO Herder stopped (org.apache.kafka.connect.runtime.standalone.StandaloneHerder:112)
[2021-02-04 13:08:17,453] INFO Kafka Connect stopped (org.apache.kafka.connect.runtime.Connect:70)

this is my connector1.properties

connector.class=io.debezium.connector.mysql.mysqlconnector
tasks.max=1
database.hostname=(puerto host)
database.port=3306
database.user=usuariodbz
database.password=12345
database.include.list=database
database.server.id=184054
database.server.name=servermysql
database.history.kafka.bootstrap.servers=(ip):6667
database.history.kafka.topic=topic

this is my connect-standalone.properties

bootstrap.servers=DNS:6667
key.converter=org.apache.kafka.connect.json.JsonConverter
value.converter=org.apache.kafka.connect.json.JsonConverter
key.converter.schemas.enable=true
value.converter.schemas.enable=true
offset.storage.file.filename=/tmp/connect.offsets
offset.flush.interval.ms=10000

plugin.path=/usr/hdp/current/kafka-broker/libs/connect-plugins/debezium-connector-mysql/*.jar

I feel that I need to configure something, but I have not found many answers regarding this problem, I would greatly appreciate any information

Hi @RonaldG, welcome to the forum!

How have you installed the connector? If the connector is under /usr/hdp/current/kafka-broker/libs/connect-plugins/debezium-connector-mysql/ does it work if you set

plugin.path=/usr/hdp/current/kafka-broker/libs/connect-plugins/debezium-connector-mysql/*.jar