Kafka Connect connector Issue (io.confluent.connect.activemq.ActiveMQSourceConnector)

[forrestliao]

Hi,

when I tried to create a Kafka connector, I got an error message.

I just run these services:

docker-compose up -d
Starting kafkacat  ... done
Starting zookeeper ... done
Starting kafka     ... done
Starting schema-registry ... done
Starting kafka-connect-01 ... done

Then, this is my next command:

curl -i -X PUT -H  "Content-Type:application/json"     http://localhost:8083/connectors/source-rabbitmq-00/config     -d '{
        "connector.class" : "io.confluent.connect.rabbitmq.RabbitMQSourceConnector",
        "kafka.topic" : "rabbit-test-00",
        "rabbitmq.queue" : "mq-kafka-test-classic",
        "rabbitmq.username": "xxxx",
        "rabbitmq.password": "xxxx",
        "rabbitmq.host": "x.x.x.x",
        "rabbitmq.port": "5672",
        "rabbitmq.virtual.host": "/",
        "confluent.license":"",
        "confluent.topic.bootstrap.servers":"kafka:29092",
        "confluent.topic.replication.factor":1,
        "value.converter": "org.apache.kafka.connect.converters.ByteArrayConverter",
        "key.converter": "org.apache.kafka.connect.storage.StringConverter"
    }'

I got this error message:

HTTP/1.1 500 Internal Server Error
Date: Tue, 24 Aug 2021 09:47:53 GMT
Content-Type: application/json
Content-Length: 4871
Server: Jetty(9.4.18.v20190429)

{"error_code":500,"message":"Failed to find any class that implements Connector and which name matches io.confluent.connect.rabbitmq.RabbitMQSourceConnector, available connectors are: PluginDesc{klass=class io.confluent.connect.activemq.ActiveMQSourceConnector, name='io.confluent.connect.activemq.ActiveMQSourceConnector', version='5.4.0-beta1', encodedVersion=5.4.0-beta1, type=source, typeName='source', location='file:/usr/share/java/kafka-connect-activemq/'}, PluginDesc{klass=class io.confluent.connect.elasticsearch.ElasticsearchSinkConnector, name='io.confluent.connect.elasticsearch.ElasticsearchSinkConnector', version='5.4.0-beta1', encodedVersion=5.4.0-beta1, type=sink, typeName='sink', location='file:/usr/share/java/kafka-connect-elasticsearch/'}, PluginDesc{klass=class io.confluent.connect.gcs.GcsSinkConnector, name='io.confluent.connect.gcs.GcsSinkConnector', version='5.0.3', encodedVersion=5.0.3, type=sink, typeName='sink', location='file:/usr/share/confluent-hub-components/confluentinc-kafka-connect-gcs/'}, PluginDesc{klass=class io.confluent.connect.ibm.mq.IbmMQSourceConnector, name='io.confluent.connect.ibm.mq.IbmMQSourceConnector', version='5.4.0-beta1', encodedVersion=5.4.0-beta1, type=source, typeName='source', location='file:/usr/share/java/kafka-connect-ibmmq/'}, PluginDesc{klass=class io.confluent.connect.jdbc.JdbcSinkConnector, name='io.confluent.connect.jdbc.JdbcSinkConnector', version='5.4.0-beta1', encodedVersion=5.4.0-beta1, type=sink, typeName='sink', location='file:/usr/share/java/kafka-connect-jdbc/'}, PluginDesc{klass=class io.confluent.connect.jdbc.JdbcSourceConnector, name='io.confluent.connect.jdbc.JdbcSourceConnector', version='5.4.0-beta1', encodedVersion=5.4.0-beta1, type=source, typeName='source', location='file:/usr/share/java/kafka-connect-jdbc/'}, PluginDesc{klass=class io.confluent.connect.jms.JmsSourceConnector, name='io.confluent.connect.jms.JmsSourceConnector', version='5.4.0-beta1', encodedVersion=5.4.0-beta1, type=source, typeName='source', location='file:/usr/share/java/kafka-connect-activemq/'}, PluginDesc{klass=class io.confluent.connect.s3.S3SinkConnector, name='io.confluent.connect.s3.S3SinkConnector', version='5.4.0-beta1', encodedVersion=5.4.0-beta1, type=sink, typeName='sink', location='file:/usr/share/java/kafka-connect-s3/'}, PluginDesc{klass=class io.confluent.connect.storage.tools.SchemaSourceConnector, name='io.confluent.connect.storage.tools.SchemaSourceConnector', version='5.4.0-ccs-beta1', encodedVersion=5.4.0-ccs-beta1, type=source, typeName='source', location='file:/usr/share/java/kafka-connect-storage-common/'}, PluginDesc{klass=class org.apache.kafka.connect.file.FileStreamSinkConnector, name='org.apache.kafka.connect.file.FileStreamSinkConnector', version='5.4.0-ccs-beta1', encodedVersion=5.4.0-ccs-beta1, type=sink, typeName='sink', location='file:/usr/share/java/kafka/'}, PluginDesc{klass=class org.apache.kafka.connect.file.FileStreamSourceConnector, name='org.apache.kafka.connect.file.FileStreamSourceConnector', version='5.4.0-ccs-beta1', encodedVersion=5.4.0-ccs-beta1, type=source, typeName='source', location='file:/usr/share/java/kafka/'}, PluginDesc{klass=class org.apache.kafka.connect.tools.MockConnector, name='org.apache.kafka.connect.tools.MockConnector', version='5.4.0-ccs-beta1', encodedVersion=5.4.0-ccs-beta1, type=connector, typeName='connector', location='file:/usr/share/java/kafka-connect-activemq/'}, PluginDesc{klass=class org.apache.kafka.connect.tools.MockSinkConnector, name='org.apache.kafka.connect.tools.MockSinkConnector', version='5.4.0-ccs-beta1', encodedVersion=5.4.0-ccs-beta1, type=sink, typeName='sink', location='file:/usr/share/java/kafka-connect-activemq/'}, PluginDesc{klass=class org.apache.kafka.connect.tools.MockSourceConnector, name='org.apache.kafka.connect.tools.MockSourceConnector', version='5.4.0-ccs-beta1', encodedVersion=5.4.0-ccs-beta1, type=source, typeName='source', location='file:/usr/share/java/kafka-connect-activemq/'}, PluginDesc{klass=class org.apache.kafka.connect.tools.SchemaSourceConnector, name='org.apache.kafka.connect.tools.SchemaSourceConnector', version='5.4.0-ccs-beta1', encodedVersion=5.4.0-ccs-beta1, type=source, typeName='source', location='file:/usr/share/java/kafka-connect-activemq/'}, PluginDesc{klass=class org.apache.kafka.connect.tools.VerifiableSinkConnector, name='org.apache.kafka.connect.tools.VerifiableSinkConnector', version='5.4.0-ccs-beta1', encodedVersion=5.4.0-ccs-beta1, type=source, typeName='source', location='file:/usr/share/java/kafka-connect-activemq/'}, PluginDesc{klass=class org.apache.kafka.connect.tools.VerifiableSourceConnector, name='org.apache.kafka.connect.tool

Could you help me, please?

[rmoff]

It looks like you've not installed the RabbitMQ connector properly. See https://rmoff.net/2020/06/19/how-to-install-connector-plugins-in-kafka-connect/ for details.

If you still need help please head to https://forum.confluent.io/ :)