curl http://localhost:8082/connectors/test-replicator/status
{"status":200,"body":{"name":"test-replicator","connector":{"state":"RUNNING","trace":null,"workerId":"standalone-worker"},"tasks":[{"state":"RUNNING","trace":null,"workerId":"standalone-worker","id":0}],"type":"SOURCE"}}root@rocketmq-connect-ff977b5b7-djdvg:~/logs/rocketmqconnect#
root@rocketmq-connect-ff977b5b7-djdvg:~/logs/rocketmqconnect# curl http://localhost:8082/connectors/test-replicator/status
{"status":200,"body":{"name":"test-replicator","connector":{"state":"RUNNING","trace":null,"workerId":"standalone-worker"},"tasks":[{"state":"FAILED","trace":"io.openmessaging.connector.api.errors.ConnectException: source connect lack of topic config\n\tat org.apache.rocketmq.connect.runtime.connectorwrapper.WorkerSourceTask.maybeCreateAndGetTopic(WorkerSourceTask.java:441)\n\tat org.apache.rocketmq.connect.runtime.connectorwrapper.WorkerSourceTask.sendRecord(WorkerSourceTask.java:237)\n\tat org.apache.rocketmq.connect.runtime.connectorwrapper.WorkerSourceTask.execute(WorkerSourceTask.java:527)\n\tat org.apache.rocketmq.connect.runtime.connectorwrapper.WorkerTask.doExecute(WorkerTask.java:119)\n\tat org.apache.rocketmq.connect.runtime.connectorwrapper.WorkerTask.doRun(WorkerTask.java:224)\n\tat org.apache.rocketmq.connect.runtime.connectorwrapper.WorkerTask.run(WorkerTask.java:244)\n\tat java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)\n\tat java.util.concurrent.FutureTask.run(FutureTask.java:266)\n\tat java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)\n\tat java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)\n\tat io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)\n\tat java.lang.Thread.run(Thread.java:750)\n","workerId":"standalone-worker","id":0}],"type":"SOURCE"}}
我的connect部署在k8s里面
服务已经是运行正常了
在我创建connector的时候一直报错
创建任务的命令如下：
curl -X GET "http://localhost:8082/connectors/test-replicator?config=%7B%22connector.class%22%3A%22org.apache.rocketmq.replicator.RmqSourceReplicator%22%2C%22source-rocketmq%22%3A%22itnio-common-rocketmq-nameserver.itnio-common.svc.dev.praise%3A9876%22%2C%22target-rocketmq%22%3A%22itnio-sms-rocketmq2-nameserver.itnio-sms.svc.dev.praise%3A9876%22%2C%22replicator-store-topic%22%3A%22replicatorTopic%22%2C%22taskDivideStrategy%22%3A%220%22%2C%22white-list%22%3A%22test_mq_sync%22%2C%22task-parallelism%22%3A%222%22%2C%22target-cluster%22%3A%22dev-sms-rocketmq-cluster%22%2C%22source-cluster%22%3A%22DefaultCluster%22%2C%22task.class%22%3A%22org.apache.rocketmq.replicator.RmqSourceTask%22%2C%22source-topic%22%3A%22test_mq_sync%22%2C%22target-topic%22%3A%22test_mq_sync_target%22%2C%22key.converter%22%3A%22org.apache.rocketmq.connect.runtime.converter.record.StringConverter%22%2C%22value.converter%22%3A%22org.apache.rocketmq.connect.runtime.converter.record.StringConverter%22%2C%22source-record-converter%22%3A%22org.apache.rocketmq.connect.runtime.converter.JsonConverter%22%7D"