Be responsible for consuming messages from producer and writing data into ding talk group.
mvn clean install -Dmaven.test.skip=true
http://${runtime-ip}:${runtime-port}/connectors/${rocketmq-ding-talk-sink-connector-name} ?config={"source-rocketmq":"${runtime-ip}:${runtime-port}","source-cluster":"${broker-cluster}","connector-class":"org.apache.rocketmq.connect.dingtalk.sink.DingTalkSinkConnector","connect-topicname" : "${connect-topicname}","webHook":"${webHook}","msgtype":"${msgtype}","secretKey":"${secretKey}"}
例子
http://localhost:8081/connectors/dingTalkConnectorSink?config={"source-rocketmq":"localhost:9876","source-cluster":"DefaultCluster", "connector-class":"org.apache.rocketmq.connect.dingtalk.sink.DingTalkSinkConnector","connect-topicname" : "ding-talk-topic","webHook":"192.168.1.2","msgtype":"text","secretKey":"xxxx"}
注:
rocketmq-ding-talk-connect
的启动依赖于rocketmq-connect-runtime
项目的启动,需将打好的所有jar
包放置到runtime
项目中pluginPaths
配置的路径后再执行上面的启动请求,该值配置在runtime
项目下的connect.conf
文件中
http://${runtime-ip}:${runtime-port}/connectors/${rocketmq-jdbc-connector-name}/stop
KEY | TYPE | Must be filled | Description | Example |
---|---|---|---|---|
webHook | String | YES | 机器人的Webhook地址 | https://oapi.dingtalk.com/robot/send?access_token=XXXXXX |
msgtype | String | NO | 消息类型 | text |
secretKey | String | NO | 密钥 | SC |
connect-topicname | String | YES | sink需要处理数据消息topic | xxxx |