Publish

id: dms_rocketmq_publish
namespace: company.team

tasks:
  - id: publish
    type: io.kestra.plugin.huawei.dms.rocketmq.Publish
    accessKeyId: "{{ secret('HUAWEI_AK') }}"
    secretAccessKey: "{{ secret('HUAWEI_SK') }}"
    nameServerAddr: "dms-instance-id.rocketmq.eu-west-101.myhuaweicloud.com:8100"
    topic: my-topic
    groupId: kestra-producer-group
    from:
      body: "Hello from Kestra!"
      tags: "order"

id: dms_rocketmq_publish_json
namespace: company.team

tasks:
  - id: publish
    type: io.kestra.plugin.huawei.dms.rocketmq.Publish
    accessKeyId: "{{ secret('HUAWEI_AK') }}"
    secretAccessKey: "{{ secret('HUAWEI_SK') }}"
    nameServerAddr: "dms-instance-id.rocketmq.eu-west-101.myhuaweicloud.com:8100"
    topic: orders
    groupId: kestra-producer-group
    serdeType: JSON
    from:
      body:
        orderId: "order-123"
        amount: 99.99
      tags: "order"