Hi Andrea, Thanks a lot for the suggestion, it helped fix the issue, I can see the plugin.
Regards, Gururaj -----Original Message----- From: Andrea Cosentino <anco...@gmail.com> Sent: dinsdag 15 maart 2022 10:18 To: users@camel.apache.org Subject: Re: Camel RabbitMQ sink connector plugin is not getting added in Kafka Connect [You don't often get email from anco...@gmail.com. Learn why this is important at http://aka.ms/LearnAboutSenderIdentification.] You don't have to copy the jar, you need to explode the tar.gz provided: https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-rabbitmq-kafka-connector/0.11.5/camel-rabbitmq-kafka-connector-0.11.5-package.tar.gz Each of the connectors from camel-kafka-connector, needs to live in their own directory in the plugin.path location. So you should have a folder with all the needed bits coming from the tar.gz. Only the jar won't work. This is also explained in the documentation: https://camel.apache.org/camel-kafka-connector/0.11.x/user-guide/getting-started/try-it-out-locally.html Il giorno mar 15 mar 2022 alle ore 10:11 Gururaj Maddodi < gururaj.madd...@6gorillas.nl> ha scritto: > Hi all, > > I'm trying a setup in which I need to push data from Kafka to RabbitMQ. > I'm using Debezium Kafka Connect base image and adding additional > plugins as required. As sink connector to RabbitMQ, I'm trying out > Camel RabbitMQ connector plugin. I've copied the plugin jar in the > plugin.path of Kafka Connect. I can see in the logs that Kafka Connect > starts up, that it find the Camel plugin jar and registers the loader: > > 2022-03-14 14:39:13,303 INFO || Loading plugin from: > /kafka/connect/camel-kafka-connectors > [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] > 2022-03-14 14:39:13,890 INFO || Registered loader: > PluginClassLoader{pluginLocation=file:/kafka/connect/camel-kafka-conne > ctors/} > [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] > > But, it doesn't seem to add the plugin to the list of connectors. > Subsequently, if I check the list of connectors using Kafka Conenct > REST API, I cannot find Camel RabbitMQ plugin. If I try to add a > connector using > "org.apache.camel.kafkaconnector.rabbitmq.CamelRabbitmqSinkConnector", > I get "Failed to find any class that implements Connector and which name > matches org.apache.camel.kafkaconnector.rabbitmq.CamelRabbitmqSinkConnector" > > If anyone had previously encountered this issue or any suggestions, > would be really helpful. > > Regards, > Gururaj > > >
