vb3328998 opened a new issue, #544: URL: https://github.com/apache/rocketmq-connect/issues/544
我的connect部署在k8s里面 服务已经是运行正常了 在我创建connector的时候一直报错 ``` 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.concur rent.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"}} ``` 创建任务的命令如下： 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-rec ord-converter%22%3A%22org.apache.rocketmq.connect.runtime.converter.JsonConverter%22%7D" -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@rocketmq.apache.org.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
