Camunda RocketMQ Connector

Find the user documentation in our Camunda Platform 8 Docs.

Build

mvn clean package

API

Input

{
  "authentication":{
    "accessKey":"secrets.ACCESS_KEY",
    "secretKey":"secrets.SECRET_KEY"
  },
  "topic":{
    "namesrvAddr": "0.0.0.0:9876",
    "groupName": "producerGroup",
    "topicName": "test"
  },
  "message": {
    "body":{
      "data":"ok"
    },
    "tag": "*",
    "key": "key"
  }
}

Output

{
  "result": {
    "messageId": "c158a652-c3e3-5511-a565-fd01a05c0c45"
  }
}

Test locally

Run unit tests

mvn clean verify

Test as local Job Worker

Use the Camunda Connector Runtime to run your function as a local Job Worker.

Element Template

The element templates can be found in the element-templates/rocketmq-connector.json file.

Build a release

Trigger the release action manually with the version x.y.z you want to release and the next SNAPSHOT version.