Produce
CertifiedPublish messages to a Huawei DMS for Kafka topic.
Produce
Certified
Publish messages to a Huawei DMS for Kafka topic.
yaml
type: io.kestra.plugin.huawei.dms.kafka.ProduceExamples
yaml
id: dms_kafka_produce
namespace: company.team
tasks:
- id: produce
type: io.kestra.plugin.huawei.dms.kafka.Produce
bootstrapServers: "dms-instance-id.kafka.eu-west-101.myhuaweicloud.com:9093"
saslMechanism: PLAIN
username: "{{ secret('DMS_KAFKA_USERNAME') }}"
password: "{{ secret('DMS_KAFKA_PASSWORD') }}"
topic: my-topic
from:
key: "order-123"
value: "Hello from Kestra!"
yaml
id: dms_kafka_produce_json
namespace: company.team
inputs:
- id: dataFile
type: FILE
tasks:
- id: produce
type: io.kestra.plugin.huawei.dms.kafka.Produce
bootstrapServers: "dms-instance-id.kafka.eu-west-101.myhuaweicloud.com:9093"
saslMechanism: PLAIN
username: "{{ secret('DMS_KAFKA_USERNAME') }}"
password: "{{ secret('DMS_KAFKA_PASSWORD') }}"
topic: orders
valueSerdeType: JSON
from: "{{ inputs.dataFile }}"
Properties
bootstrapServers *Requiredstring
from *RequiredNon-dynamicobject
accessKeyId string
domainId string
keySerdeType string
Default
STRINGPossible Values
STRINGJSONBINARYpassword string
projectId string
region string
saslMechanism string
Default
PLAINPossible Values
PLAINSCRAM_SHA_512NONEsecretAccessKey string
securityToken string
sslEnabled booleanstring
Default
falsetemporaryCredentials 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
topic string
username string
valueSerdeType string
Default
STRINGPossible Values
STRINGJSONBINARYOutputs
messagesCount integer
Metrics
dms.kafka.produce.count counter
Unit
records
