Star
Contact SalesGet Started
    • Core Features
    • Enterprise Edition
    • Cloud EditionRequest Access
    • Platform Overview
    • Use-cases

    • Data Workflow
    • Infrastructure Automation
    • AI Workflows

      Users

    • Data Engineers
    • Software Engineers
    • Platform Engineers

      Industries

    • Finance
    • Automotive
    • Retail
    • Healthcare
    • Public Services
    • Software & Services
  • Plugins
    • Docs
    • Integrations
    • Blueprints
    • Blog
    • Customer Stories
    • Courses
    • Events
    • About Us
    • Newsroom
    • CareersHiring!
    • Partners
    • Contact us
  • Pricing
  • Get Started Join us on SlackBook a Demo
  • Core Features
  • Enterprise Edition
  • Cloud EditionRequest Access
  • Platform Overview

Use-cases

  • Data Workflow
  • Infrastructure Automation
  • AI Workflows

Users

  • Data Engineers
  • Software Engineers
  • Platform Engineers

Industries

  • Finance
  • Automotive
  • Retail
  • Healthcare
  • Public Services
  • Software & Services
  • Docs
  • Integrations
  • Blueprints
  • Blog
  • Customer Stories
  • Courses
  • Events
  • About Us
  • Newsroom
  • CareersHiring!
  • Partners
  • Contact us
ESC
Ask Kestra AI
ESC
Kestra AI

Hi! I'm your Kestra AI assistant.
Ask me anything about workflows.

EXAMPLE QUESTIONS

How to sync my flows with Git?
How to run Python script?
How to run dbt?

Huawei

Huawei DataArts Studio
  • GetJobRun
  • StartJobRun
  • StopJobRun
Huawei IAM
  • GetTemporaryCredentials
Huawei SMN
  • Publish
Huawei EventGrid
  • PutEvents
Huawei CES
  • Push
  • Query
  • Trigger
Huawei DIS
  • Consume
  • PutRecords
  • RealtimeTrigger
  • Trigger
Huawei MRS
  • CreateClusterAndSubmitJob
  • DeleteCluster
  • SubmitJob
Huawei SWR
  • GetAuthToken
Huawei DMS for Kafka
  • Consume
  • Produce
  • RealtimeTrigger
  • Trigger
Huawei DMS for RocketMQ
  • Consume
  • Publish
  • RealtimeTrigger
  • Trigger
Huawei DLI
  • Query
Huawei KooCLI
  • KooCLI
Huawei OBS
  • Copy
  • CreateBucket
  • Delete
  • DeleteBucket
  • DeleteList
  • Download
  • Downloads
  • List
  • Upload
  • Trigger
Huawei GeminiDB
  • DeleteItem
  • GetItem
  • PutItem
  • Query
  • Scan
Huawei RFS
  • Create
  • Delete
Huawei FunctionGraph
  • Invoke

Request a plugin

Ask on Slack

Create a plugin

Go to the developer platform
OVERVIEW

Plugins have a Min. Compatible Kestra Version i.e. a Kestra version from where the corresponding plugin version is compatible. Learn More

Versions
October 12, 2026 Release Notes Min.compatible Kestra ver.: 1.3.39

Maintained by

Kestra iconKestra Core Team
See all contributors

Plugin Type

DataInfrastructure

Links & Resources

GitHub
Table of Contents
  • Tasks
  • Triggers
  • More Plugins in this Category
Get Involved
  • GitHub
  • Join Us on Slack
  • YouTube
  • LinkedIn
  • Reddit
  • Twitter
  • Bluesky
Share this Plugin
  1. Plugins
  2. Huawei
  3. Huawei DMS for RocketMQ

Huawei DMS for RocketMQ

Huawei DMS for RocketMQ

Certified

Publish, consume, trigger, and react to messages on Huawei Cloud DMS for RocketMQ

tasks

Consume

Consume messages from a Huawei DMS for RocketMQ topic

io.kestra.plugin.huawei.dms.rocketmq.Consume
Publish

Publish messages to a Huawei DMS for RocketMQ topic

io.kestra.plugin.huawei.dms.rocketmq.Publish

triggers

RealtimeTrigger

Trigger a flow for each message on a Huawei DMS for RocketMQ topic

io.kestra.plugin.huawei.dms.rocketmq.RealtimeTrigger
Trigger

Trigger a flow when new messages arrive on a Huawei DMS for RocketMQ topic

io.kestra.plugin.huawei.dms.rocketmq.Trigger

More Plugins in this Category

Twilio
Twilio

Tasks that integrate with the Twilio ecosystem.

BusinessData

9 tasks

3 blueprints

AMQP
AMQP

Tasks that connect to RabbitMQ brokers to declare exchanges and queues, bind routing keys, publish messages, and consume them via tasks or triggers (batch or real time), plus AMQP 1.0 tasks for brokers such as Azure Service Bus and ActiveMQ Artemis.

DataInfrastructure

10 tasks

5 blueprints

Get Kestra Updates

SOC 2GDPR
Kestra's logo

Open Source Declarative
Orchestration Platform

Get Started
  • Getting Started
  • Documentation
  • Blueprints
  • Plugins
  • FAQs
Learn
  • Blogs
  • Resources
  • Videos
  • Kestra Academy
  • Administrator Guide
  • Release Notes
  • API Reference
Resources
  • All Comparisons
  • All Integrations
  • Resources Center
Industries
  • Finance
  • Healthcare
  • Public Services
  • Software & Services
  • Retail
  • Automotive
Community
  • Community Overview
  • Slack
  • GitHub
  • Write for Us
Company
  • About Us
  • Partners
  • Careers Hiring!
  • Security
  • Contact

© 2026 Kestra Technologies. Developed with ♥ on 🌎.

Privacy PolicyCookie Policy