Hi, I’d like to use debezium to sink to Mongodb database. I use the image Quay for debezium connector.
But when I try to register a sink using curl -i -X POST -H "Accept:application/json" -H "Content-Type:application/json" localhost:8083/connectors/ -d @debezium/sink_mongodb.json
I get the error
HTTP/1.1 500 Internal Server Error
Date: Mon, 21 Oct 2024 10:34:09 GMT
Content-Type: application/json
Content-Length: 4105
Server: Jetty(9.4.53.v20231009)
{"error_code":500,"message":"Failed to find any class that implements Connector and which name matches com.mongodb.kafka.connect.MongoSinkConnector, available connectors are: PluginDesc{klass=class io.debezium.connector.db2.Db2Connector, name='io.debezium.connector.db2.Db2Connector', version='2.7.3.Final', encodedVersion=2.7.3.Final, type=source, typeName='source', location='file:/kafka/connect/debezium-connector-db2/'}, PluginDesc{klass=class io.debezium.connector.db2as400.As400RpcConnector, name='io.debezium.connector.db2as400.As400RpcConnector', version='2.7.3.Final', encodedVersion=2.7.3.Final, type=source, typeName='source', location='file:/kafka/connect/debezium-connector-ibmi/'}, PluginDesc{klass=class io.debezium.connector.informix.InformixConnector, name='io.debezium.connector.informix.InformixConnector', version='2.7.3.Final', encodedVersion=2.7.3.Final, type=source, typeName='source', location='file:/kafka/connect/debezium-connector-informix/'}, PluginDesc{klass=class io.debezium.connector.jdbc.JdbcSinkConnector, name='io.debezium.connector.jdbc.JdbcSinkConnector', version='2.7.3.Final', encodedVersion=2.7.3.Final, type=sink, typeName='sink', location='file:/kafka/connect/debezium-connector-jdbc/'}, PluginDesc{klass=class io.debezium.connector.mariadb.MariaDbConnector, name='io.debezium.connector.mariadb.MariaDbConnector', version='2.7.3.Final', encodedVersion=2.7.3.Final, type=source, typeName='source', location='file:/kafka/connect/debezium-connector-mariadb/'}, PluginDesc{klass=class io.debezium.connector.mongodb.MongoDbConnector, name='io.debezium.connector.mongodb.MongoDbConnector', version='2.7.3.Final', encodedVersion=2.7.3.Final, 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='2.7.3.Final', encodedVersion=2.7.3.Final, 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='2.7.3.Final', encodedVersion=2.7.3.Final, 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='2.7.3.Final', encodedVersion=2.7.3.Final, type=source, typeName='source', location='file:/kafka/connect/debezium-connector-postgres/'}, PluginDesc{klass=class io.debezium.connector.spanner.SpannerConnector, name='io.debezium.connector.spanner.SpannerConnector', version='2.7.3.Final', encodedVersion=2.7.3.Final, type=source, typeName='source', location='file:/kafka/connect/debezium-connector-spanner/'}, PluginDesc{klass=class io.debezium.connector.sqlserver.SqlServerConnector, name='io.debezium.connector.sqlserver.SqlServerConnector', version='2.7.3.Final', encodedVersion=2.7.3.Final, type=source, typeName='source', location='file:/kafka/connect/debezium-connector-sqlserver/'}, PluginDesc{klass=class io.debezium.connector.vitess.VitessConnector, name='io.debezium.connector.vitess.VitessConnector', version='2.7.3.Final', encodedVersion=2.7.3.Final, type=source, typeName='source', location='file:/kafka/connect/debezium-connector-vitess/'}, PluginDesc{klass=class org.apache.kafka.connect.mirror.MirrorCheckpointConnector, name='org.apache.kafka.connect.mirror.MirrorCheckpointConnector', version='3.7.0', encodedVersion=3.7.0, type=source, typeName='source', location='classpath'}, PluginDesc{klass=class org.apache.kafka.connect.mirror.MirrorHeartbeatConnector, name='org.apache.kafka.connect.mirror.MirrorHeartbeatConnector', version='3.7.0', encodedVersion=3.7.0, type=source, typeName='source', location='classpath'}, PluginDesc{klass=class org.apache.kafka.connect.mirror.MirrorSourceConnector, name='org.apache.kafka.connect.mirror.MirrorSourceConnector', version='3.7.0', encodedVersion=3.7.0, type=source, typeName='source', location='classpath'}"}%
Please how to integrate this connector into the docker image ? My question is very newby but I can’t find any relevant doc on this. This article https://mongodb.prakticum-team.ru/docs/kafka-connector/current/introduction/install/ does not seem to consider the docker case.