Skip to content
Permalink
Browse files
fixed googlepubsub itests.
  • Loading branch information
valdar committed Oct 30, 2021
1 parent 9355af9 commit f03ff05edbd59e0c95dc7e2bf1ae03a61718c0bf
Showing 8 changed files with 862 additions and 3 deletions.
@@ -0,0 +1,213 @@
{
"connector": {
"class": "org.apache.camel.kafkaconnector.hwclouddms.CamelHwclouddmsSinkConnector",
"artifactId": "camel-hwcloud-dms-kafka-connector",
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-hwcloud-dms-sink",
"type": "sink",
"version": "0.12.0-SNAPSHOT",
"description": "To integrate with a fully managed, high-performance message queuing service on Huawei Cloud"
},
"properties": {
"camel.sink.path.operation": {
"name": "camel.sink.path.operation",
"description": "Operation to be performed",
"priority": "HIGH",
"required": "true"
},
"camel.sink.endpoint.accessKey": {
"name": "camel.sink.endpoint.accessKey",
"description": "Access key for the cloud user",
"priority": "HIGH",
"required": "true"
},
"camel.sink.endpoint.accessUser": {
"name": "camel.sink.endpoint.accessUser",
"description": "The username of a RabbitMQ instance. This option is mandatory when creating a RabbitMQ instance.",
"priority": "MEDIUM",
"required": "false"
},
"camel.sink.endpoint.availableZones": {
"name": "camel.sink.endpoint.availableZones",
"description": "The ID of an available zone. This option is mandatory when creating an instance and it cannot be an empty array.",
"priority": "MEDIUM",
"required": "false"
},
"camel.sink.endpoint.endpoint": {
"name": "camel.sink.endpoint.endpoint",
"description": "DMS url. Carries higher precedence than region parameter based client initialization",
"priority": "MEDIUM",
"required": "false"
},
"camel.sink.endpoint.engine": {
"name": "camel.sink.endpoint.engine",
"description": "The message engine. Either kafka or rabbitmq. If the parameter is not specified, all instances will be queried One of: [kafka] [rabbitmq]",
"priority": "MEDIUM",
"required": "false",
"enum": [
"kafka",
"rabbitmq"
]
},
"camel.sink.endpoint.engineVersion": {
"name": "camel.sink.endpoint.engineVersion",
"description": "The version of the message engine. This option is mandatory when creating an instance.",
"priority": "MEDIUM",
"required": "false"
},
"camel.sink.endpoint.ignoreSslVerification": {
"name": "camel.sink.endpoint.ignoreSslVerification",
"description": "Ignore SSL verification",
"defaultValue": "false",
"priority": "MEDIUM",
"required": "false"
},
"camel.sink.endpoint.instanceId": {
"name": "camel.sink.endpoint.instanceId",
"description": "The id of the instance. This option is mandatory when deleting or querying an instance",
"priority": "MEDIUM",
"required": "false"
},
"camel.sink.endpoint.kafkaManagerPassword": {
"name": "camel.sink.endpoint.kafkaManagerPassword",
"description": "The password for logging in to the Kafka Manager. This option is mandatory when creating a Kafka instance.",
"priority": "MEDIUM",
"required": "false"
},
"camel.sink.endpoint.kafkaManagerUser": {
"name": "camel.sink.endpoint.kafkaManagerUser",
"description": "The username for logging in to the Kafka Manager. This option is mandatory when creating a Kafka instance.",
"priority": "MEDIUM",
"required": "false"
},
"camel.sink.endpoint.lazyStartProducer": {
"name": "camel.sink.endpoint.lazyStartProducer",
"description": "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.",
"defaultValue": "false",
"priority": "MEDIUM",
"required": "false"
},
"camel.sink.endpoint.name": {
"name": "camel.sink.endpoint.name",
"description": "The name of the instance for creating and updating an instance. This option is mandatory when creating an instance",
"priority": "MEDIUM",
"required": "false"
},
"camel.sink.endpoint.partitionNum": {
"name": "camel.sink.endpoint.partitionNum",
"description": "The maximum number of partitions in a Kafka instance. This option is mandatory when creating a Kafka instance.",
"priority": "MEDIUM",
"required": "false"
},
"camel.sink.endpoint.password": {
"name": "camel.sink.endpoint.password",
"description": "The password of a RabbitMQ instance. This option is mandatory when creating a RabbitMQ instance.",
"priority": "MEDIUM",
"required": "false"
},
"camel.sink.endpoint.productId": {
"name": "camel.sink.endpoint.productId",
"description": "The product ID. This option is mandatory when creating an instance.",
"priority": "MEDIUM",
"required": "false"
},
"camel.sink.endpoint.projectId": {
"name": "camel.sink.endpoint.projectId",
"description": "Cloud project ID",
"priority": "HIGH",
"required": "true"
},
"camel.sink.endpoint.proxyHost": {
"name": "camel.sink.endpoint.proxyHost",
"description": "Proxy server ip\/hostname",
"priority": "MEDIUM",
"required": "false"
},
"camel.sink.endpoint.proxyPassword": {
"name": "camel.sink.endpoint.proxyPassword",
"description": "Proxy authentication password",
"priority": "MEDIUM",
"required": "false"
},
"camel.sink.endpoint.proxyPort": {
"name": "camel.sink.endpoint.proxyPort",
"description": "Proxy server port",
"priority": "MEDIUM",
"required": "false"
},
"camel.sink.endpoint.proxyUser": {
"name": "camel.sink.endpoint.proxyUser",
"description": "Proxy authentication user",
"priority": "MEDIUM",
"required": "false"
},
"camel.sink.endpoint.region": {
"name": "camel.sink.endpoint.region",
"description": "DMS service region",
"priority": "HIGH",
"required": "true"
},
"camel.sink.endpoint.secretKey": {
"name": "camel.sink.endpoint.secretKey",
"description": "Secret key for the cloud user",
"priority": "HIGH",
"required": "true"
},
"camel.sink.endpoint.securityGroupId": {
"name": "camel.sink.endpoint.securityGroupId",
"description": "The security group which the instance belongs to. This option is mandatory when creating an instance.",
"priority": "MEDIUM",
"required": "false"
},
"camel.sink.endpoint.serviceKeys": {
"name": "camel.sink.endpoint.serviceKeys",
"description": "Configuration object for cloud service authentication",
"priority": "MEDIUM",
"required": "false"
},
"camel.sink.endpoint.specification": {
"name": "camel.sink.endpoint.specification",
"description": "The baseline bandwidth of a Kafka instance. This option is mandatory when creating a Kafka instance.",
"priority": "MEDIUM",
"required": "false"
},
"camel.sink.endpoint.storageSpace": {
"name": "camel.sink.endpoint.storageSpace",
"description": "The message storage space. This option is mandatory when creating an instance.",
"priority": "MEDIUM",
"required": "false"
},
"camel.sink.endpoint.storageSpecCode": {
"name": "camel.sink.endpoint.storageSpecCode",
"description": "The storage I\/O specification. This option is mandatory when creating an instance.",
"priority": "MEDIUM",
"required": "false"
},
"camel.sink.endpoint.subnetId": {
"name": "camel.sink.endpoint.subnetId",
"description": "The subnet ID. This option is mandatory when creating an instance.",
"priority": "MEDIUM",
"required": "false"
},
"camel.sink.endpoint.vpcId": {
"name": "camel.sink.endpoint.vpcId",
"description": "The VPC ID. This option is mandatory when creating an instance.",
"priority": "MEDIUM",
"required": "false"
},
"camel.component.hwcloud-dms.lazyStartProducer": {
"name": "camel.component.hwcloud-dms.lazyStartProducer",
"description": "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.",
"defaultValue": "false",
"priority": "MEDIUM",
"required": "false"
},
"camel.component.hwcloud-dms.autowiredEnabled": {
"name": "camel.component.hwcloud-dms.autowiredEnabled",
"description": "Whether autowiring is enabled. This is used for automatic autowiring options (the option must be marked as autowired) by looking up in the registry to find if there is a single instance of matching type, which then gets configured on the component. This can be used for automatic configuring JDBC data sources, JMS connection factories, AWS Clients, etc.",
"defaultValue": "true",
"priority": "MEDIUM",
"required": "false"
}
}
}
@@ -0,0 +1,139 @@
{
"connector": {
"class": "org.apache.camel.kafkaconnector.hwcloudimagerecognition.CamelHwcloudimagerecognitionSinkConnector",
"artifactId": "camel-hwcloud-imagerecognition-kafka-connector",
"groupId": "org.apache.camel.kafkaconnector",
"id": "camel-hwcloud-imagerecognition-sink",
"type": "sink",
"version": "0.12.0-SNAPSHOT",
"description": "To identify objects, scenes, and concepts in images on Huawei Cloud"
},
"properties": {
"camel.sink.path.operation": {
"name": "camel.sink.path.operation",
"description": "Name of Image Recognition operation to perform, including celebrityRecognition and tagRecognition",
"priority": "HIGH",
"required": "true"
},
"camel.sink.endpoint.accessKey": {
"name": "camel.sink.endpoint.accessKey",
"description": "Access key for the cloud user",
"priority": "HIGH",
"required": "true"
},
"camel.sink.endpoint.endpoint": {
"name": "camel.sink.endpoint.endpoint",
"description": "Fully qualified Image Recognition service url. Carries higher precedence than region based configuration.",
"priority": "MEDIUM",
"required": "false"
},
"camel.sink.endpoint.imageContent": {
"name": "camel.sink.endpoint.imageContent",
"description": "Indicates the Base64 character string converted from the image. The size cannot exceed 10 MB. The image resolution of the narrow sides must be greater than 15 pixels, and that of the wide sides cannot exceed 4096 pixels.The supported image formats include JPG, PNG, and BMP. Configure either this parameter or imageUrl, and this one carries higher precedence than imageUrl.",
"priority": "MEDIUM",
"required": "false"
},
"camel.sink.endpoint.imageUrl": {
"name": "camel.sink.endpoint.imageUrl",
"description": "Indicates the URL of an image. The options are as follows: HTTP\/HTTPS URLs on the public network OBS URLs. To use OBS data, authorization is required, including service authorization, temporary authorization, and anonymous public authorization. For details, see Configuring the Access Permission of OBS. Configure either this parameter or imageContent, and this one carries lower precedence than imageContent.",
"priority": "MEDIUM",
"required": "false"
},
"camel.sink.endpoint.lazyStartProducer": {
"name": "camel.sink.endpoint.lazyStartProducer",
"description": "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.",
"defaultValue": "false",
"priority": "MEDIUM",
"required": "false"
},
"camel.sink.endpoint.projectId": {
"name": "camel.sink.endpoint.projectId",
"description": "Cloud project ID",
"priority": "HIGH",
"required": "true"
},
"camel.sink.endpoint.proxyHost": {
"name": "camel.sink.endpoint.proxyHost",
"description": "Proxy server ip\/hostname",
"priority": "MEDIUM",
"required": "false"
},
"camel.sink.endpoint.proxyPassword": {
"name": "camel.sink.endpoint.proxyPassword",
"description": "Proxy authentication password",
"priority": "MEDIUM",
"required": "false"
},
"camel.sink.endpoint.proxyPort": {
"name": "camel.sink.endpoint.proxyPort",
"description": "Proxy server port",
"priority": "MEDIUM",
"required": "false"
},
"camel.sink.endpoint.proxyUser": {
"name": "camel.sink.endpoint.proxyUser",
"description": "Proxy authentication user",
"priority": "MEDIUM",
"required": "false"
},
"camel.sink.endpoint.region": {
"name": "camel.sink.endpoint.region",
"description": "Image Recognition service region. Currently only cn-north-1 and cn-north-4 are supported. This is lower precedence than endpoint based configuration.",
"priority": "HIGH",
"required": "true"
},
"camel.sink.endpoint.secretKey": {
"name": "camel.sink.endpoint.secretKey",
"description": "Secret key for the cloud user",
"priority": "HIGH",
"required": "true"
},
"camel.sink.endpoint.serviceKeys": {
"name": "camel.sink.endpoint.serviceKeys",
"description": "Configuration object for cloud service authentication",
"priority": "MEDIUM",
"required": "false"
},
"camel.sink.endpoint.tagLanguage": {
"name": "camel.sink.endpoint.tagLanguage",
"description": "Indicates the language of the returned tags when the operation is tagRecognition, including zh and en.",
"defaultValue": "\"zh\"",
"priority": "MEDIUM",
"required": "false"
},
"camel.sink.endpoint.tagLimit": {
"name": "camel.sink.endpoint.tagLimit",
"description": "Indicates the maximum number of the returned tags when the operation is tagRecognition.",
"defaultValue": "50",
"priority": "MEDIUM",
"required": "false"
},
"camel.sink.endpoint.threshold": {
"name": "camel.sink.endpoint.threshold",
"description": "Indicates the threshold of confidence. When the operation is tagRecognition, this parameter ranges from 0 to 100. Tags whose confidence score is lower than the threshold will not be returned. The default value is 60. When the operation is celebrityRecognition, this parameter ranges from 0 to 1. Labels whose confidence score is lower than the threshold will not be returned. The default value is 0.48.",
"priority": "MEDIUM",
"required": "false"
},
"camel.sink.endpoint.ignoreSslVerification": {
"name": "camel.sink.endpoint.ignoreSslVerification",
"description": "Ignore SSL verification",
"defaultValue": "false",
"priority": "MEDIUM",
"required": "false"
},
"camel.component.hwcloud-imagerecognition.lazyStartProducer": {
"name": "camel.component.hwcloud-imagerecognition.lazyStartProducer",
"description": "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.",
"defaultValue": "false",
"priority": "MEDIUM",
"required": "false"
},
"camel.component.hwcloud-imagerecognition.autowiredEnabled": {
"name": "camel.component.hwcloud-imagerecognition.autowiredEnabled",
"description": "Whether autowiring is enabled. This is used for automatic autowiring options (the option must be marked as autowired) by looking up in the registry to find if there is a single instance of matching type, which then gets configured on the component. This can be used for automatic configuring JDBC data sources, JMS connection factories, AWS Clients, etc.",
"defaultValue": "true",
"priority": "MEDIUM",
"required": "false"
}
}
}

0 comments on commit f03ff05

Please sign in to comment.