How can i migrant from kafka to rocketmq?

[pc-gh]

There are my steps：

• 1、run Worker

It can work normal,console show the message "The standalone worker boot success.".

• 2、change the config file and restart Worker

i set plugin path value as your recommand

pluginPaths=/usr/local/connector-plugins

• 3、add connect-kafka plugin

I try to package the module "rocketmq-connect-kafka",but i got a pom file.then i change pom.xml,let packaging labe value equal jar,then i got a jar file.And i push it to the plugin path.i also restarted Worker by the script "sh bin/connectshutdown.sh".

• 4、create source connect-kafka

I create connect kafka by url like this:

http://127.0.0.1:8081/connectors/connector-name?config={"connector.class":"org.apache.rocketmq.connect.kafka.connector.KafkaSourceConnector","tasks.num":"1","kafka.topics":"test1,test2","kafka.group.id":"group0","kafka.bootstrap.server":"127.0.0.1:9092","source-record-converter":"org.apache.rocketmq.connect.runtime.converter.JsonConverter"}

however i got the response:

{
    "errorCode": 500,
    "message": "Failed to find any class that implements Connector and which name matches org.apache.rocketmq.connect.kafka.connector.KafkaSourceConnector, available connectors are: PluginWrapper{klass=class org.apache.rocketmq.connect.file.FileSinkConnector, name='org.apache.rocketmq.connect.file.FileSinkConnector', type=sink, typeName='sink', location='classpath', version='undefined', encodedVersion=undefined, classLoader=sun.misc.Launcher$ExtClassLoader@19469ea2}, PluginWrapper{klass=class org.apache.rocketmq.connect.file.FileSourceConnector, name='org.apache.rocketmq.connect.file.FileSourceConnector', type=source, typeName='source', location='classpath', version='undefined', encodedVersion=undefined, classLoader=sun.misc.Launcher$ExtClassLoader@19469ea2}"
}

Did i overlook something important?Hope your reply!

[zhongxig]

1. Explain: "Failed to find": means "connector-plugins" didn't contains "org.apache.rocketmq.connect.kafka.connector.KafkaSourceConnector" plugin-jar.
2. Cause: maybe "3、add connect-kafka plugin" has something error. let me see.