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-connectors/}
[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
