This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-spring-boot.git
The following commit(s) were added to refs/heads/main by this push:
new 9142d648e62 Regen
9142d648e62 is described below
commit 9142d648e62bb0e9a59b29b3879138b8a29beb53
Author: Andrea Cosentino <[email protected]>
AuthorDate: Fri Jul 22 15:21:01 2022 +0200
Regen
---
.../catalog/components/aws2-eventbridge.json | 9 +++++---
.../catalog/components/azure-eventhubs.json | 7 +++++-
.../src/main/docs/azure-eventhubs.json | 14 ++++++++++++
.../EventHubsComponentConfiguration.java | 26 ++++++++++++++++++++++
4 files changed, 52 insertions(+), 4 deletions(-)
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/aws2-eventbridge.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/aws2-eventbridge.json
index fbe81e8dfef..d12463bd497 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/aws2-eventbridge.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/aws2-eventbridge.json
@@ -26,7 +26,7 @@
"eventbridgeClient": { "kind": "property", "displayName": "Eventbridge
Client", "group": "producer", "label": "", "required": false, "type": "object",
"javaType": "software.amazon.awssdk.services.eventbridge.EventBridgeClient",
"deprecated": false, "deprecationNote": "", "autowired": true, "secret": false,
"configurationClass":
"org.apache.camel.component.aws2.eventbridge.EventbridgeConfiguration",
"configurationField": "configuration", "description": "To use a existing
configured AW [...]
"eventPatternFile": { "kind": "property", "displayName": "Event Pattern
File", "group": "producer", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.aws2.eventbridge.EventbridgeConfiguration",
"configurationField": "configuration", "description": "EventPattern File" },
"lazyStartProducer": { "kind": "property", "displayName": "Lazy Start
Producer", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "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 star [...]
- "operation": { "kind": "property", "displayName": "Operation", "group":
"producer", "label": "", "required": true, "type": "object", "javaType":
"org.apache.camel.component.aws2.eventbridge.EventbridgeOperations", "enum": [
"putRule", "putTargets", "removeTargets", "deleteRule", "enableRule",
"disableRule", "describeRule", "listRules", "listTargetsByRule",
"listRuleNamesByTarget" ], "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "defaultValue": "putR [...]
+ "operation": { "kind": "property", "displayName": "Operation", "group":
"producer", "label": "", "required": true, "type": "object", "javaType":
"org.apache.camel.component.aws2.eventbridge.EventbridgeOperations", "enum": [
"putRule", "putTargets", "removeTargets", "deleteRule", "enableRule",
"disableRule", "describeRule", "listRules", "listTargetsByRule",
"listRuleNamesByTarget", "putEvent" ], "deprecated": false, "deprecationNote":
"", "autowired": false, "secret": false, "defaultV [...]
"overrideEndpoint": { "kind": "property", "displayName": "Override
Endpoint", "group": "producer", "label": "", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.aws2.eventbridge.EventbridgeConfiguration",
"configurationField": "configuration", "description": "Set the need for
overidding the endpoint. This option needs to be used in combination [...]
"pojoRequest": { "kind": "property", "displayName": "Pojo Request",
"group": "producer", "label": "", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.aws2.eventbridge.EventbridgeConfiguration",
"configurationField": "configuration", "description": "If we want to use a POJO
request as body or not" },
"proxyHost": { "kind": "property", "displayName": "Proxy Host", "group":
"producer", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.aws2.eventbridge.EventbridgeConfiguration",
"configurationField": "configuration", "description": "To define a proxy host
when instantiating the Eventbridge client" },
@@ -47,13 +47,16 @@
"CamelAwsEventbridgeEventPattern": { "kind": "header", "displayName": "",
"group": "producer", "label": "", "required": false, "javaType": "String",
"deprecated": false, "deprecationNote": "", "autowired": false, "secret":
false, "description": "The event pattern.", "constantName":
"org.apache.camel.component.aws2.eventbridge.EventbridgeConstants#EVENT_PATTERN"
},
"CamelAwsEventbridgeTargets": { "kind": "header", "displayName": "",
"group": "producer", "label": "", "required": false, "javaType":
"Collection<Target>", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "The targets to update or add to the
rule.", "constantName":
"org.apache.camel.component.aws2.eventbridge.EventbridgeConstants#TARGETS" },
"CamelAwsEventbridgeTargetsIds": { "kind": "header", "displayName": "",
"group": "producer", "label": "", "required": false, "javaType":
"Collection<String>", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "The IDs of the targets to remove from
the rule.", "constantName":
"org.apache.camel.component.aws2.eventbridge.EventbridgeConstants#TARGETS_IDS"
},
- "CamelAwsEventbridgeTargetArn": { "kind": "header", "displayName": "",
"group": "producer", "label": "", "required": false, "javaType": "String",
"deprecated": false, "deprecationNote": "", "autowired": false, "secret":
false, "description": "The Amazon Resource Name (ARN) of the target resource.",
"constantName":
"org.apache.camel.component.aws2.eventbridge.EventbridgeConstants#TARGET_ARN" }
+ "CamelAwsEventbridgeTargetArn": { "kind": "header", "displayName": "",
"group": "producer", "label": "", "required": false, "javaType": "String",
"deprecated": false, "deprecationNote": "", "autowired": false, "secret":
false, "description": "The Amazon Resource Name (ARN) of the target resource.",
"constantName":
"org.apache.camel.component.aws2.eventbridge.EventbridgeConstants#TARGET_ARN" },
+ "CamelAwsEventbridgeResourcesArn": { "kind": "header", "displayName": "",
"group": "producer", "label": "", "required": false, "javaType": "String",
"deprecated": false, "deprecationNote": "", "autowired": false, "secret":
false, "description": "Comma separated list of Amazon Resource Names (ARN) of
the resources related to Event", "constantName":
"org.apache.camel.component.aws2.eventbridge.EventbridgeConstants#EVENT_RESOURCES_ARN"
},
+ "CamelAwsEventbridgeSource": { "kind": "header", "displayName": "",
"group": "producer", "label": "", "required": false, "javaType": "String",
"deprecated": false, "deprecationNote": "", "autowired": false, "secret":
false, "description": "The source related to Event", "constantName":
"org.apache.camel.component.aws2.eventbridge.EventbridgeConstants#EVENT_SOURCE"
},
+ "CamelAwsEventbridgeDetailType": { "kind": "header", "displayName": "",
"group": "producer", "label": "", "required": false, "javaType": "String",
"deprecated": false, "deprecationNote": "", "autowired": false, "secret":
false, "description": "The detail type related to Event", "constantName":
"org.apache.camel.component.aws2.eventbridge.EventbridgeConstants#EVENT_DETAIL_TYPE"
}
},
"properties": {
"eventbusNameOrArn": { "kind": "path", "displayName": "Eventbus Name Or
Arn", "group": "producer", "label": "", "required": true, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "description": "Event bus name or ARN" },
"eventbridgeClient": { "kind": "parameter", "displayName": "Eventbridge
Client", "group": "producer", "label": "", "required": false, "type": "object",
"javaType": "software.amazon.awssdk.services.eventbridge.EventBridgeClient",
"deprecated": false, "deprecationNote": "", "autowired": true, "secret": false,
"configurationClass":
"org.apache.camel.component.aws2.eventbridge.EventbridgeConfiguration",
"configurationField": "configuration", "description": "To use a existing
configured A [...]
"eventPatternFile": { "kind": "parameter", "displayName": "Event Pattern
File", "group": "producer", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.aws2.eventbridge.EventbridgeConfiguration",
"configurationField": "configuration", "description": "EventPattern File" },
- "operation": { "kind": "parameter", "displayName": "Operation", "group":
"producer", "label": "", "required": true, "type": "object", "javaType":
"org.apache.camel.component.aws2.eventbridge.EventbridgeOperations", "enum": [
"putRule", "putTargets", "removeTargets", "deleteRule", "enableRule",
"disableRule", "describeRule", "listRules", "listTargetsByRule",
"listRuleNamesByTarget" ], "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "defaultValue": "put [...]
+ "operation": { "kind": "parameter", "displayName": "Operation", "group":
"producer", "label": "", "required": true, "type": "object", "javaType":
"org.apache.camel.component.aws2.eventbridge.EventbridgeOperations", "enum": [
"putRule", "putTargets", "removeTargets", "deleteRule", "enableRule",
"disableRule", "describeRule", "listRules", "listTargetsByRule",
"listRuleNamesByTarget", "putEvent" ], "deprecated": false, "deprecationNote":
"", "autowired": false, "secret": false, "default [...]
"overrideEndpoint": { "kind": "parameter", "displayName": "Override
Endpoint", "group": "producer", "label": "", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.aws2.eventbridge.EventbridgeConfiguration",
"configurationField": "configuration", "description": "Set the need for
overidding the endpoint. This option needs to be used in combinatio [...]
"pojoRequest": { "kind": "parameter", "displayName": "Pojo Request",
"group": "producer", "label": "", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.aws2.eventbridge.EventbridgeConfiguration",
"configurationField": "configuration", "description": "If we want to use a POJO
request as body or not" },
"proxyHost": { "kind": "parameter", "displayName": "Proxy Host", "group":
"producer", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.aws2.eventbridge.EventbridgeConfiguration",
"configurationField": "configuration", "description": "To define a proxy host
when instantiating the Eventbridge client" },
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/azure-eventhubs.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/azure-eventhubs.json
index da1edbb57ed..9a65a3cc876 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/azure-eventhubs.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/azure-eventhubs.json
@@ -30,6 +30,8 @@
"blobContainerName": { "kind": "property", "displayName": "Blob Container
Name", "group": "consumer", "label": "consumer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "In case you chose the
default BlobCheckpointStore, this sets the blob container that shall b [...]
"blobStorageSharedKeyCredential": { "kind": "property", "displayName":
"Blob Storage Shared Key Credential", "group": "consumer", "label": "consumer",
"required": false, "type": "object", "javaType":
"com.azure.storage.common.StorageSharedKeyCredential", "deprecated": false,
"autowired": false, "secret": true, "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "In case you chose the
default [...]
"bridgeErrorHandler": { "kind": "property", "displayName": "Bridge Error
Handler", "group": "consumer", "label": "consumer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "Allows for bridging the
consumer to the Camel routing Error Handler, which mean any exceptions occurred
while the consumer is trying to pickup incoming messages, or the likes, will
now be processed as a me [...]
+ "checkpointBatchSize": { "kind": "property", "displayName": "Checkpoint
Batch Size", "group": "consumer", "label": "consumer", "required": false,
"type": "integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 500, "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "Sets the batch size
between each checkpoint updates. Works jointly with checkpo [...]
+ "checkpointBatchTimeout": { "kind": "property", "displayName": "Checkpoint
Batch Timeout", "group": "consumer", "label": "consumer", "required": false,
"type": "integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 5000, "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "Sets the batch timeout
between each checkpoint updates. Works jointly wi [...]
"checkpointStore": { "kind": "property", "displayName": "Checkpoint
Store", "group": "consumer", "label": "consumer", "required": false, "type":
"object", "javaType": "com.azure.messaging.eventhubs.CheckpointStore",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"BlobCheckpointStore", "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "Sets the CheckpointStore
the [...]
"consumerGroupName": { "kind": "property", "displayName": "Consumer Group
Name", "group": "consumer", "label": "consumer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "$Default", "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "Sets the name of the
consumer group this consumer is associated [...]
"eventPosition": { "kind": "property", "displayName": "Event Position",
"group": "consumer", "label": "consumer", "required": false, "type": "object",
"javaType": "java.util.Map<java.lang.String,
com.azure.messaging.eventhubs.models.EventPosition>", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "Sets the map containing
the event [...]
@@ -50,7 +52,8 @@
"CamelAzureEventHubsEnqueuedTime": { "kind": "header", "displayName": "",
"group": "consumer", "label": "consumer", "required": false, "javaType":
"Instant", "deprecated": false, "deprecationNote": "", "autowired": false,
"secret": false, "description": "It sets the instant, in UTC, of when the event
was enqueued in the Event Hub partition. This is only present on a received
EventData.", "constantName":
"org.apache.camel.component.azure.eventhubs.EventHubsConstants#ENQUEUED_TIME" },
"CamelAzureEventHubsSequenceNumber": { "kind": "header", "displayName":
"", "group": "consumer", "label": "consumer", "required": false, "javaType":
"Long", "deprecated": false, "deprecationNote": "", "autowired": false,
"secret": false, "description": "It sets the sequence number assigned to the
event when it was enqueued in the associated Event Hub partition. This is
unique for every message received in the Event Hub partition. This is only
present on a received EventData.", "const [...]
"CamelAzureEventHubsMetadata": { "kind": "header", "displayName": "",
"group": "consumer", "label": "consumer", "required": false, "javaType":
"Map<String, Object>", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "The set of free-form event properties
which may be used for passing metadata associated with the event with the event
body during Event Hubs operations.", "constantName":
"org.apache.camel.component.azure.eventhubs.EventHubsC [...]
- "CamelMessageTimestamp": { "kind": "header", "displayName": "", "group":
"consumer", "label": "consumer", "required": false, "javaType": "long",
"deprecated": false, "deprecationNote": "", "autowired": false, "secret":
false, "description": "The timestamp of the message", "constantName":
"org.apache.camel.component.azure.eventhubs.EventHubsConstants#MESSAGE_TIMESTAMP"
}
+ "CamelMessageTimestamp": { "kind": "header", "displayName": "", "group":
"consumer", "label": "consumer", "required": false, "javaType": "long",
"deprecated": false, "deprecationNote": "", "autowired": false, "secret":
false, "description": "The timestamp of the message", "constantName":
"org.apache.camel.component.azure.eventhubs.EventHubsConstants#MESSAGE_TIMESTAMP"
},
+ "CamelAzureEventHubsCheckpointUpdatedBy": { "kind": "header",
"displayName": "", "group": "consumer", "label": "consumer", "required": false,
"javaType": "String", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "It sets the reason for the checkpoint
to have been updated. This is only present on a received EventData.",
"constantName":
"org.apache.camel.component.azure.eventhubs.EventHubsConstants#CHECKPOINT_UPDATED_BY"
}
},
"properties": {
"namespace": { "kind": "path", "displayName": "Namespace", "group":
"common", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "EventHubs namespace
created in Azure Portal" },
@@ -61,6 +64,8 @@
"blobAccountName": { "kind": "parameter", "displayName": "Blob Account
Name", "group": "consumer", "label": "consumer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "In case you chose the
default BlobCheckpointStore, this sets Azure account name to be used for [...]
"blobContainerName": { "kind": "parameter", "displayName": "Blob Container
Name", "group": "consumer", "label": "consumer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "In case you chose the
default BlobCheckpointStore, this sets the blob container that shall [...]
"blobStorageSharedKeyCredential": { "kind": "parameter", "displayName":
"Blob Storage Shared Key Credential", "group": "consumer", "label": "consumer",
"required": false, "type": "object", "javaType":
"com.azure.storage.common.StorageSharedKeyCredential", "deprecated": false,
"autowired": false, "secret": true, "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "In case you chose the
default [...]
+ "checkpointBatchSize": { "kind": "parameter", "displayName": "Checkpoint
Batch Size", "group": "consumer", "label": "consumer", "required": false,
"type": "integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 500, "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "Sets the batch size
between each checkpoint updates. Works jointly with checkp [...]
+ "checkpointBatchTimeout": { "kind": "parameter", "displayName":
"Checkpoint Batch Timeout", "group": "consumer", "label": "consumer",
"required": false, "type": "integer", "javaType": "int", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": 5000,
"configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "Sets the batch timeout
between each checkpoint updates. Works jointly w [...]
"checkpointStore": { "kind": "parameter", "displayName": "Checkpoint
Store", "group": "consumer", "label": "consumer", "required": false, "type":
"object", "javaType": "com.azure.messaging.eventhubs.CheckpointStore",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"BlobCheckpointStore", "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "Sets the CheckpointStore
the [...]
"consumerGroupName": { "kind": "parameter", "displayName": "Consumer Group
Name", "group": "consumer", "label": "consumer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "$Default", "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "Sets the name of the
consumer group this consumer is associated [...]
"eventPosition": { "kind": "parameter", "displayName": "Event Position",
"group": "consumer", "label": "consumer", "required": false, "type": "object",
"javaType": "java.util.Map<java.lang.String,
com.azure.messaging.eventhubs.models.EventPosition>", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.eventhubs.EventHubsConfiguration",
"configurationField": "configuration", "description": "Sets the map containing
the event [...]
diff --git
a/components-starter/camel-azure-eventhubs-starter/src/main/docs/azure-eventhubs.json
b/components-starter/camel-azure-eventhubs-starter/src/main/docs/azure-eventhubs.json
index 360defd5044..3b6059d6fe0 100644
---
a/components-starter/camel-azure-eventhubs-starter/src/main/docs/azure-eventhubs.json
+++
b/components-starter/camel-azure-eventhubs-starter/src/main/docs/azure-eventhubs.json
@@ -63,6 +63,20 @@
"sourceType":
"org.apache.camel.component.azure.eventhubs.springboot.EventHubsComponentConfiguration",
"defaultValue": false
},
+ {
+ "name": "camel.component.azure-eventhubs.checkpoint-batch-size",
+ "type": "java.lang.Integer",
+ "description": "Sets the batch size between each checkpoint updates.
Works jointly with checkpointBatchTimeout",
+ "sourceType":
"org.apache.camel.component.azure.eventhubs.springboot.EventHubsComponentConfiguration",
+ "defaultValue": 500
+ },
+ {
+ "name": "camel.component.azure-eventhubs.checkpoint-batch-timeout",
+ "type": "java.lang.Integer",
+ "description": "Sets the batch timeout between each checkpoint updates.
Works jointly with checkpointBatchSize",
+ "sourceType":
"org.apache.camel.component.azure.eventhubs.springboot.EventHubsComponentConfiguration",
+ "defaultValue": 5000
+ },
{
"name": "camel.component.azure-eventhubs.checkpoint-store",
"type": "com.azure.messaging.eventhubs.CheckpointStore",
diff --git
a/components-starter/camel-azure-eventhubs-starter/src/main/java/org/apache/camel/component/azure/eventhubs/springboot/EventHubsComponentConfiguration.java
b/components-starter/camel-azure-eventhubs-starter/src/main/java/org/apache/camel/component/azure/eventhubs/springboot/EventHubsComponentConfiguration.java
index 5ee8ea29f51..f18492d8056 100644
---
a/components-starter/camel-azure-eventhubs-starter/src/main/java/org/apache/camel/component/azure/eventhubs/springboot/EventHubsComponentConfiguration.java
+++
b/components-starter/camel-azure-eventhubs-starter/src/main/java/org/apache/camel/component/azure/eventhubs/springboot/EventHubsComponentConfiguration.java
@@ -94,6 +94,16 @@ public class EventHubsComponentConfiguration
* will be logged at WARN or ERROR level and ignored.
*/
private Boolean bridgeErrorHandler = false;
+ /**
+ * Sets the batch size between each checkpoint updates. Works jointly with
+ * checkpointBatchTimeout
+ */
+ private Integer checkpointBatchSize = 500;
+ /**
+ * Sets the batch timeout between each checkpoint updates. Works jointly
+ * with checkpointBatchSize
+ */
+ private Integer checkpointBatchTimeout = 5000;
/**
* Sets the CheckpointStore the EventProcessorClient will use for storing
* partition ownership and checkpoint information. Users can, optionally,
@@ -258,6 +268,22 @@ public class EventHubsComponentConfiguration
this.bridgeErrorHandler = bridgeErrorHandler;
}
+ public Integer getCheckpointBatchSize() {
+ return checkpointBatchSize;
+ }
+
+ public void setCheckpointBatchSize(Integer checkpointBatchSize) {
+ this.checkpointBatchSize = checkpointBatchSize;
+ }
+
+ public Integer getCheckpointBatchTimeout() {
+ return checkpointBatchTimeout;
+ }
+
+ public void setCheckpointBatchTimeout(Integer checkpointBatchTimeout) {
+ this.checkpointBatchTimeout = checkpointBatchTimeout;
+ }
+
public CheckpointStore getCheckpointStore() {
return checkpointStore;
}
