How can i migrant from kafka to rocketmq?

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!