Search code examples
apache-kafkaapache-kafka-connectcdcdebeziumconfluent-platform

How to add kafka-connect-jdbc-5.5.0.jar to Debezium/connect


i had downloaded the kafka-connect-jdbc-5.5.0.jar file from confluent into my local machine.i would like to know a way to add this jar to plugin.path=/kafka/connect. i am trying to sink the data to mysql server so iam using "connector.class": "io.confluent.connect.jdbc.JdbcSinkConnector" but i am facing the "error_code":500,"message":"Failed to find any class that implements Connector and which name matches io.confluent.connect.jdbc.JdbcSinkConnector, i am using docker toolbox in windows machine


Solution

  • Please check this examle Dockerfile. It demonstrates how to deploy sink connector for JDBC and Elasticsearch. Generally the most important to remeber is that if plagin.path is set to /kafka/connect then the connector but be dpeloyed in a directory named /kafka/connect/<arbitrary_name_dirname>.