DMS for RocketMQ¶

Sample event¶

dms4rocketmq_event.json¶

{
  "event_version": "v1.0",
  "event_time": 1576737962,
  "trigger_type": "ROCKETMQ",
  "region": "eu-de",
  "instance_id": "08fd3e1b-cf56-401f-b4c6-81fd2a1d3ae6",
  "records": [
      {
          "messages": [
              "kafka message1",
              "kafka message2",
              "kafka message3",
              "kafka message4",
              "kafka message5"
          ],
          "topic_id": "topic-test"
      }
  ]
}

Class definitions¶

For class definitions for DMS for RocketMQ trigger event, see: Classe definitions

Sample¶

For sample on how to use trigger, see: Sample

last updated: 2025-09-23 09:31:56 UTC - commit: 70dfd27683766d95e95edd34387e5c0f102dbc02