Consume
CertifiedConsume messages from a Huawei DMS for RocketMQ topic.
Consume
Certified
Consume messages from a Huawei DMS for RocketMQ topic.
yaml
type: io.kestra.plugin.huawei.dms.rocketmq.ConsumeExamples
yaml
id: dms_rocketmq_consume
namespace: company.team
tasks:
- id: consume
type: io.kestra.plugin.huawei.dms.rocketmq.Consume
accessKeyId: "{{ secret('HUAWEI_AK') }}"
secretAccessKey: "{{ secret('HUAWEI_SK') }}"
nameServerAddr: "dms-instance-id.rocketmq.eu-west-101.myhuaweicloud.com:8100"
topic: my-topic
groupId: kestra-consumer-group
maxRecords: 50
Properties
groupId *Requiredstring
nameServerAddr *Requiredstring
topic *Requiredstring
accessKeyId string
domainId string
instanceId string
maxDuration string
maxRecords integerstring
projectId string
region string
secretAccessKey string
securityToken string
serdeType string
Default
STRINGPossible Values
STRINGJSONtemporaryCredentials string
Definitions
io.kestra.plugin.huawei.TemporaryCredentialsConfig
authMethodstring
Default
PASSWORDPossible Values
PASSWORDTOKENdomainNamestring
durationSecondsintegerstring
Default
900endpointSuffixstring
Default
myhuaweicloud.comiamTokenstring
passwordstring
projectNamestring
scopestring
Default
PROJECTPossible Values
PROJECTDOMAINusernamestring
Outputs
messagesCount integer
uri string
Format
uriMetrics
dms.rocketmq.consume.count counter
Unit
messages
