rocketmq-connect-fc

• rocketmq-connect-fc 说明

Be responsible for consuming messages from producer and writing data to function calculation FC.

rocketmq-connect-fc 打包

mvn clean install -Dmaven.test.skip=true

rocketmq-connect-fc 启动

• fc-sink-connector 启动

http://${runtime-ip}:${runtime-port}/connectors/${rocketmq-fc-sink-connector-name}
?config={"source-rocketmq":"${runtime-ip}:${runtime-port}","source-cluster":"${broker-cluster}","connector-class":"org.apache.rocketmq.connect.fc.sink.FcSinkConnector","connect-topicname" : "${connect-topicname}",“region”:"${region}",accessKey”:"${accessKey}",accessSecretKey”:"${accessSecretKey}",accountId”:"${accountId}","serviceName":"${serviceName}","functionName":"${functionName}","invocationType":"${invocationType}", "qualifier":"${qualifier}"}

例子

http://localhost:8081/connectors/fcConnectorSink?config={"source-rocketmq":"localhost:9876","source-cluster":"DefaultCluster",
"connector-class":"org.apache.rocketmq.connect.fc.sink.FcSinkConnector","connect-topicname" : "fc-topic",“region”:"cn-hangzhou",accessKey”:"xxxx",accessSecretKey”:"xxxx",accountId”:"xxxx","serviceName":"xxxx","functionName":"xxxx","invocationType":"", "qualifier":"LATEST"}

注： rocketmq-fc-connect 的启动依赖于rocketmq-connect-runtime项目的启动，需将打好的所有jar包放置到runtime项目中pluginPaths配置的路径后再执行上面的启动请求,该值配置在runtime项目下的connect.conf文件中

rocketmq-connect-fc 停止

http://${runtime-ip}:${runtime-port}/connectors/${rocketmq-fc-connector-name}/stop

rocketmq-connect-fc 参数说明

• fc-sink-connector 参数说明