rocketmq-connect-doris集成任务正确启动命令是什么样的?

Viewed 6

在使用rocketmq-connect-doris集成rocketmq数据到doris时,
按照README.txt指南编写集成任务:

curl -X POST -H "Content-Type: application/json" http://127.0.0.1:8082/connectors/jdbc-doris-sink-test -d '{
"connector.class":"org.apache.rocketmq.connect.doris.connector.DorisSinkConnector",
"max.tasks":"1",
"table.whitelist":"sink_test.doris_test_sink",
"connect.topicname":"doris_test_sink",
"connect.topicnames":"doris_test_sink",
"host":"192.168.0.1",
"port":"7030",
"user":"****",
"passwd":"*****",
"database":"db_1",
"insert.mode":"INSERT",
"db.timezone":"UTC",
"table.types":"TABLE",
"auto.create":"true",
"source-record-converter":"org.apache.rocketmq.connect.runtime.converter.JsonConverter",
"key.converter":"org.apache.rocketmq.connect.runtime.converter.record.json.JsonConverter",
"value.converter":"org.apache.rocketmq.connect.runtime.converter.record.json.JsonConverter"
}'

一直报空指针错误,少配置,经过代码检查发现确实这份文档中的内容和实际相差甚远,但是根据代码不能完全拼凑出完整的启动命令
请问有正确的示例吗?期待您的回复!

0 Answers