Huawei Distributed Message Service (DMS)

To integrate with a fully managed, high-performance message queuing service on Huawei Cloud

Metadata

Property	Value
Scheme	`hwcloud-dms`
Support Level	Stable
Labels	cloud
Version	4.10.2

Maven Dependency

<dependency>
    <groupId>org.apache.camel</groupId>
    <artifactId>camel-huaweicloud-dms</artifactId>
    <version>4.10.2</version>
</dependency>

Endpoint Properties

Name	Type	Required	Default	Description
`operation`	string	✓		Operation to be performed
`accessKey`	string	✓		Access key for the cloud user
`accessUser`	string			The username of a RabbitMQ instance. This option is mandatory when creating a RabbitMQ instance.
`availableZones`	array			The ID of an available zone. This option is mandatory when creating an instance and it cannot be an empty array.
`endpoint`	string			DMS url. Carries higher precedence than region parameter based client initialization
`engine`	string			The message engine. Either kafka or rabbitmq. If the parameter is not specified, all instances will be queried
`engineVersion`	string			The version of the message engine. This option is mandatory when creating an instance.
`ignoreSslVerification`	boolean		`false`	Ignore SSL verification
`instanceId`	string			The id of the instance. This option is mandatory when deleting or querying an instance
`kafkaManagerPassword`	string			The password for logging in to the Kafka Manager. This option is mandatory when creating a Kafka instance.
`kafkaManagerUser`	string			The username for logging in to the Kafka Manager. This option is mandatory when creating a Kafka instance.
`name`	string			The name of the instance for creating and updating an instance. This option is mandatory when creating an instance
`partitionNum`	integer			The maximum number of partitions in a Kafka instance. This option is mandatory when creating a Kafka instance.
`password`	string			The password of a RabbitMQ instance. This option is mandatory when creating a RabbitMQ instance.
`productId`	string			The product ID. This option is mandatory when creating an instance.
`projectId`	string	✓		Cloud project ID
`proxyHost`	string			Proxy server ip/hostname
`proxyPassword`	string			Proxy authentication password
`proxyPort`	integer			Proxy server port
`proxyUser`	string			Proxy authentication user
`region`	string	✓		DMS service region
`secretKey`	string	✓		Secret key for the cloud user
`securityGroupId`	string			The security group which the instance belongs to. This option is mandatory when creating an instance.
`serviceKeys`	object			Configuration object for cloud service authentication
`specification`	string			The baseline bandwidth of a Kafka instance. This option is mandatory when creating a Kafka instance.
`storageSpace`	integer			The message storage space. This option is mandatory when creating an instance.
`storageSpecCode`	string			The storage I/O specification. This option is mandatory when creating an instance.
`subnetId`	string			The subnet ID. This option is mandatory when creating an instance.
`vpcId`	string			The VPC ID. This option is mandatory when creating an instance.
`lazyStartProducer`	boolean		`false`	Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a producer may otherwise fail during starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel's routing error handlers. Beware that when the first message is processed then creating and starting the producer may take a little time and prolong the total processing time of the processing.