[create-pull-request] automated change

apache · Mar 6, 2025 · 8d336bf · 8d336bf
1 parent 363f6e3
commit 8d336bf
Show file tree

Hide file tree

Showing 41 changed files with 207 additions and 60 deletions.
diff --git a/...d/resources/connectors/camel-kafka-batch-apicurio-registry-not-secured-source-source.json b/...d/resources/connectors/camel-kafka-batch-apicurio-registry-not-secured-source-source.json
@@ -102,6 +102,12 @@
 			"priority": "MEDIUM",
 			"required": "false"
 		},
+		"camel.kamelet.kafka-batch-apicurio-registry-not-secured-source.batchingIntervalMs": {
+			"name": "camel.kamelet.kafka-batch-apicurio-registry-not-secured-source.batchingIntervalMs",
+			"description": "In consumer batching mode, then this option is specifying a time in millis, to trigger batch completion eager when the current batch size has not reached the maximum size defined by maxPollRecords. Notice the trigger is not exact at the given interval, as this can only happen between kafka polls (see pollTimeoutMs option).",
+			"priority": "MEDIUM",
+			"required": "false"
+		},
 		"camel.kamelet.kafka-batch-apicurio-registry-not-secured-source.topicIsPattern": {
 			"name": "camel.kamelet.kafka-batch-apicurio-registry-not-secured-source.topicIsPattern",
 			"description": "Whether the topic is a pattern (regular expression). This can be used to subscribe to dynamic number of topics matching the pattern.",

diff --git a/...src/generated/resources/connectors/camel-kafka-batch-apicurio-registry-source-source.json b/...src/generated/resources/connectors/camel-kafka-batch-apicurio-registry-source-source.json
@@ -102,6 +102,12 @@
 			"priority": "MEDIUM",
 			"required": "false"
 		},
+		"camel.kamelet.kafka-batch-apicurio-registry-source.batchingIntervalMs": {
+			"name": "camel.kamelet.kafka-batch-apicurio-registry-source.batchingIntervalMs",
+			"description": "In consumer batching mode, then this option is specifying a time in millis, to trigger batch completion eager when the current batch size has not reached the maximum size defined by maxPollRecords. Notice the trigger is not exact at the given interval, as this can only happen between kafka polls (see pollTimeoutMs option).",
+			"priority": "MEDIUM",
+			"required": "false"
+		},
 		"camel.kamelet.kafka-batch-apicurio-registry-source.apicurioAuthServiceUrl": {
 			"name": "camel.kamelet.kafka-batch-apicurio-registry-source.apicurioAuthServiceUrl",
 			"description": "The URL for Keycloak instance securing the Apicurio Registry Example: http:\/\/my-keycloak.com:8080\/",

diff --git a/...generated/resources/connectors/camel-kafka-batch-azure-schema-registry-source-source.json b/...generated/resources/connectors/camel-kafka-batch-azure-schema-registry-source-source.json
@@ -121,6 +121,12 @@
 			"priority": "MEDIUM",
 			"required": "false"
 		},
+		"camel.kamelet.kafka-batch-azure-schema-registry-source.batchingIntervalMs": {
+			"name": "camel.kamelet.kafka-batch-azure-schema-registry-source.batchingIntervalMs",
+			"description": "In consumer batching mode, then this option is specifying a time in millis, to trigger batch completion eager when the current batch size has not reached the maximum size defined by maxPollRecords. Notice the trigger is not exact at the given interval, as this can only happen between kafka polls (see pollTimeoutMs option).",
+			"priority": "MEDIUM",
+			"required": "false"
+		},
 		"camel.kamelet.kafka-batch-azure-schema-registry-source.topicIsPattern": {
 			"name": "camel.kamelet.kafka-batch-azure-schema-registry-source.topicIsPattern",
 			"description": "Whether the topic is a pattern (regular expression). This can be used to subscribe to dynamic number of topics matching the pattern.",

diff --git a/...talog/src/generated/resources/connectors/camel-kafka-batch-not-secured-source-source.json b/...talog/src/generated/resources/connectors/camel-kafka-batch-not-secured-source-source.json
@@ -82,6 +82,12 @@
 			"priority": "MEDIUM",
 			"required": "false"
 		},
+		"camel.kamelet.kafka-batch-not-secured-source.batchingIntervalMs": {
+			"name": "camel.kamelet.kafka-batch-not-secured-source.batchingIntervalMs",
+			"description": "In consumer batching mode, then this option is specifying a time in millis, to trigger batch completion eager when the current batch size has not reached the maximum size defined by maxPollRecords. Notice the trigger is not exact at the given interval, as this can only happen between kafka polls (see pollTimeoutMs option).",
+			"priority": "MEDIUM",
+			"required": "false"
+		},
 		"camel.kamelet.kafka-batch-not-secured-source.topicIsPattern": {
 			"name": "camel.kamelet.kafka-batch-not-secured-source.topicIsPattern",
 			"description": "Whether the topic is a pattern (regular expression). This can be used to subscribe to dynamic number of topics matching the pattern.",

diff --git a/...tor-catalog/src/generated/resources/connectors/camel-kafka-batch-scram-source-source.json b/...tor-catalog/src/generated/resources/connectors/camel-kafka-batch-scram-source-source.json
@@ -108,6 +108,12 @@
 			"priority": "MEDIUM",
 			"required": "false"
 		},
+		"camel.kamelet.kafka-batch-scram-source.batchingIntervalMs": {
+			"name": "camel.kamelet.kafka-batch-scram-source.batchingIntervalMs",
+			"description": "In consumer batching mode, then this option is specifying a time in millis, to trigger batch completion eager when the current batch size has not reached the maximum size defined by maxPollRecords. Notice the trigger is not exact at the given interval, as this can only happen between kafka polls (see pollTimeoutMs option).",
+			"priority": "MEDIUM",
+			"required": "false"
+		},
 		"camel.kamelet.kafka-batch-scram-source.topicIsPattern": {
 			"name": "camel.kamelet.kafka-batch-scram-source.topicIsPattern",
 			"description": "Whether the topic is a pattern (regular expression). This can be used to subscribe to dynamic number of topics matching the pattern.",

diff --git a/...connector-catalog/src/generated/resources/connectors/camel-kafka-batch-source-source.json b/...connector-catalog/src/generated/resources/connectors/camel-kafka-batch-source-source.json
@@ -108,6 +108,12 @@
 			"priority": "MEDIUM",
 			"required": "false"
 		},
+		"camel.kamelet.kafka-batch-source.batchingIntervalMs": {
+			"name": "camel.kamelet.kafka-batch-source.batchingIntervalMs",
+			"description": "In consumer batching mode, then this option is specifying a time in millis, to trigger batch completion eager when the current batch size has not reached the maximum size defined by maxPollRecords. Notice the trigger is not exact at the given interval, as this can only happen between kafka polls (see pollTimeoutMs option).",
+			"priority": "MEDIUM",
+			"required": "false"
+		},
 		"camel.kamelet.kafka-batch-source.topicIsPattern": {
 			"name": "camel.kamelet.kafka-batch-source.topicIsPattern",
 			"description": "Whether the topic is a pattern (regular expression). This can be used to subscribe to dynamic number of topics matching the pattern.",

diff --git a/...ector-catalog/src/generated/resources/connectors/camel-kafka-batch-ssl-source-source.json b/...ector-catalog/src/generated/resources/connectors/camel-kafka-batch-ssl-source-source.json
@@ -147,6 +147,12 @@
 			"priority": "MEDIUM",
 			"required": "false"
 		},
+		"camel.kamelet.kafka-batch-ssl-source.batchingIntervalMs": {
+			"name": "camel.kamelet.kafka-batch-ssl-source.batchingIntervalMs",
+			"description": "In consumer batching mode, then this option is specifying a time in millis, to trigger batch completion eager when the current batch size has not reached the maximum size defined by maxPollRecords. Notice the trigger is not exact at the given interval, as this can only happen between kafka polls (see pollTimeoutMs option).",
+			"priority": "MEDIUM",
+			"required": "false"
+		},
 		"camel.kamelet.kafka-batch-ssl-source.topicIsPattern": {
 			"name": "camel.kamelet.kafka-batch-ssl-source.topicIsPattern",
 			"description": "Whether the topic is a pattern (regular expression). This can be used to subscribe to dynamic number of topics matching the pattern.",

diff --git a/connectors/camel-kafka-azure-schema-registry-sink-kafka-connector/pom.xml b/connectors/camel-kafka-azure-schema-registry-sink-kafka-connector/pom.xml
@@ -49,14 +49,19 @@
       <groupId>org.apache.camel</groupId>
       <artifactId>camel-core</artifactId>
     </dependency>
+    <dependency>
+      <groupId>org.apache.camel.kafkaconnector</groupId>
+      <artifactId>camel-kafka-connector</artifactId>
+    </dependency>
     <dependency>
       <groupId>com.azure</groupId>
       <artifactId>azure-data-schemaregistry-apacheavro</artifactId>
-      <version>1.1.22</version>
+      <version>1.1.23</version>
     </dependency>
     <dependency>
-      <groupId>org.apache.camel.kafkaconnector</groupId>
-      <artifactId>camel-kafka-connector</artifactId>
+      <groupId>com.azure</groupId>
+      <artifactId>azure-identity</artifactId>
+      <version>1.15.0</version>
     </dependency>
     <dependency>
       <groupId>org.apache.camel</groupId>
@@ -71,11 +76,6 @@
       <artifactId>azure-schemaregistry-kafka-avro</artifactId>
       <version>1.1.1</version>
     </dependency>
-    <dependency>
-      <groupId>com.azure</groupId>
-      <artifactId>azure-identity</artifactId>
-      <version>1.14.0</version>
-    </dependency>
     <dependency>
       <groupId>org.apache.camel</groupId>
       <artifactId>camel-kamelet</artifactId>

diff --git a/...kafka-connector/src/main/resources/kamelets/kafka-azure-schema-registry-sink.kamelet.yaml b/...kafka-connector/src/main/resources/kamelets/kafka-azure-schema-registry-sink.kamelet.yaml
@@ -95,8 +95,8 @@ spec:
     - "camel:kamelet"
     - "camel:azure-schema-registry"
     - "mvn:com.microsoft.azure:azure-schemaregistry-kafka-avro:1.1.1"
-    - "mvn:com.azure:azure-data-schemaregistry-apacheavro:1.1.22"
-    - "mvn:com.azure:azure-identity:1.14.0"
+    - "mvn:com.azure:azure-data-schemaregistry-apacheavro:1.1.23"
+    - "mvn:com.azure:azure-identity:1.15.0"
   template:
     beans:
       - name: defaultAzureCredential

diff --git a/connectors/camel-kafka-azure-schema-registry-source-kafka-connector/pom.xml b/connectors/camel-kafka-azure-schema-registry-source-kafka-connector/pom.xml
@@ -49,14 +49,19 @@
       <groupId>org.apache.camel</groupId>
       <artifactId>camel-core</artifactId>
     </dependency>
+    <dependency>
+      <groupId>org.apache.camel.kafkaconnector</groupId>
+      <artifactId>camel-kafka-connector</artifactId>
+    </dependency>
     <dependency>
       <groupId>com.azure</groupId>
       <artifactId>azure-data-schemaregistry-apacheavro</artifactId>
-      <version>1.1.22</version>
+      <version>1.1.23</version>
     </dependency>
     <dependency>
-      <groupId>org.apache.camel.kafkaconnector</groupId>
-      <artifactId>camel-kafka-connector</artifactId>
+      <groupId>com.azure</groupId>
+      <artifactId>azure-identity</artifactId>
+      <version>1.15.0</version>
     </dependency>
     <dependency>
       <groupId>org.apache.camel</groupId>
@@ -71,11 +76,6 @@
       <artifactId>azure-schemaregistry-kafka-avro</artifactId>
       <version>1.1.1</version>
     </dependency>
-    <dependency>
-      <groupId>com.azure</groupId>
-      <artifactId>azure-identity</artifactId>
-      <version>1.14.0</version>
-    </dependency>
     <dependency>
       <groupId>org.apache.camel</groupId>
       <artifactId>camel-kamelet</artifactId>

diff --git a/...fka-connector/src/main/resources/kamelets/kafka-azure-schema-registry-source.kamelet.yaml b/...fka-connector/src/main/resources/kamelets/kafka-azure-schema-registry-source.kamelet.yaml
@@ -136,8 +136,8 @@ spec:
     - "camel:kamelet"
     - "camel:azure-schema-registry"
     - "mvn:com.microsoft.azure:azure-schemaregistry-kafka-avro:1.1.1"
-    - "mvn:com.azure:azure-data-schemaregistry-apacheavro:1.1.22"
-    - "mvn:com.azure:azure-identity:1.14.0"
+    - "mvn:com.azure:azure-data-schemaregistry-apacheavro:1.1.23"
+    - "mvn:com.azure:azure-identity:1.15.0"
   template:
     beans:
       - name: defaultAzureCredential

diff --git a/connectors/camel-kafka-batch-apicurio-registry-not-secured-source-kafka-connector/pom.xml b/connectors/camel-kafka-batch-apicurio-registry-not-secured-source-kafka-connector/pom.xml
@@ -49,6 +49,11 @@
       <groupId>org.apache.camel.kafkaconnector</groupId>
       <artifactId>camel-kafka-connector</artifactId>
     </dependency>
+    <dependency>
+      <groupId>io.quarkus</groupId>
+      <artifactId>quarkus-apicurio-registry-avro</artifactId>
+      <version>3.18.1</version>
+    </dependency>
     <dependency>
       <groupId>org.apache.camel</groupId>
       <artifactId>camel-kafka</artifactId>
@@ -61,11 +66,6 @@
       <groupId>org.apache.camel</groupId>
       <artifactId>camel-kamelet</artifactId>
     </dependency>
-    <dependency>
-      <groupId>io.quarkus</groupId>
-      <artifactId>quarkus-apicurio-registry-avro</artifactId>
-      <version>3.6.3</version>
-    </dependency>
     <!--END OF GENERATED CODE-->
   </dependencies>
   <build>

diff --git a/...rc/generated/resources/camel-kafka-batch-apicurio-registry-not-secured-source-source.json b/...rc/generated/resources/camel-kafka-batch-apicurio-registry-not-secured-source-source.json
@@ -102,6 +102,12 @@
 			"priority": "MEDIUM",
 			"required": "false"
 		},
+		"camel.kamelet.kafka-batch-apicurio-registry-not-secured-source.batchingIntervalMs": {
+			"name": "camel.kamelet.kafka-batch-apicurio-registry-not-secured-source.batchingIntervalMs",
+			"description": "In consumer batching mode, then this option is specifying a time in millis, to trigger batch completion eager when the current batch size has not reached the maximum size defined by maxPollRecords. Notice the trigger is not exact at the given interval, as this can only happen between kafka polls (see pollTimeoutMs option).",
+			"priority": "MEDIUM",
+			"required": "false"
+		},
 		"camel.kamelet.kafka-batch-apicurio-registry-not-secured-source.topicIsPattern": {
 			"name": "camel.kamelet.kafka-batch-apicurio-registry-not-secured-source.topicIsPattern",
 			"description": "Whether the topic is a pattern (regular expression). This can be used to subscribe to dynamic number of topics matching the pattern.",

diff --git a/...otsecuredsource/CamelKafkabatchapicurioregistrynotsecuredsourceSourceConnectorConfig.java b/...otsecuredsource/CamelKafkabatchapicurioregistrynotsecuredsourceSourceConnectorConfig.java
@@ -68,6 +68,9 @@ public class CamelKafkabatchapicurioregistrynotsecuredsourceSourceConnectorConfi
     public static final String CAMEL_SOURCE_KAFKABATCHAPICURIOREGISTRYNOTSECUREDSOURCE_KAMELET_MAX_POLL_INTERVAL_MS_CONF = "camel.kamelet.kafka-batch-apicurio-registry-not-secured-source.maxPollIntervalMs";
     public static final String CAMEL_SOURCE_KAFKABATCHAPICURIOREGISTRYNOTSECUREDSOURCE_KAMELET_MAX_POLL_INTERVAL_MS_DOC = "The maximum delay between invocations of poll() when using consumer group management";
     public static final Integer CAMEL_SOURCE_KAFKABATCHAPICURIOREGISTRYNOTSECUREDSOURCE_KAMELET_MAX_POLL_INTERVAL_MS_DEFAULT = null;
+    public static final String CAMEL_SOURCE_KAFKABATCHAPICURIOREGISTRYNOTSECUREDSOURCE_KAMELET_BATCHING_INTERVAL_MS_CONF = "camel.kamelet.kafka-batch-apicurio-registry-not-secured-source.batchingIntervalMs";
+    public static final String CAMEL_SOURCE_KAFKABATCHAPICURIOREGISTRYNOTSECUREDSOURCE_KAMELET_BATCHING_INTERVAL_MS_DOC = "In consumer batching mode, then this option is specifying a time in millis, to trigger batch completion eager when the current batch size has not reached the maximum size defined by maxPollRecords. Notice the trigger is not exact at the given interval, as this can only happen between kafka polls (see pollTimeoutMs option).";
+    public static final Integer CAMEL_SOURCE_KAFKABATCHAPICURIOREGISTRYNOTSECUREDSOURCE_KAMELET_BATCHING_INTERVAL_MS_DEFAULT = null;
     public static final String CAMEL_SOURCE_KAFKABATCHAPICURIOREGISTRYNOTSECUREDSOURCE_KAMELET_TOPIC_IS_PATTERN_CONF = "camel.kamelet.kafka-batch-apicurio-registry-not-secured-source.topicIsPattern";
     public static final String CAMEL_SOURCE_KAFKABATCHAPICURIOREGISTRYNOTSECUREDSOURCE_KAMELET_TOPIC_IS_PATTERN_DOC = "Whether the topic is a pattern (regular expression). This can be used to subscribe to dynamic number of topics matching the pattern.";
     public static final Boolean CAMEL_SOURCE_KAFKABATCHAPICURIOREGISTRYNOTSECUREDSOURCE_KAMELET_TOPIC_IS_PATTERN_DEFAULT = false;
@@ -99,6 +102,7 @@ public static ConfigDef conf() {
         conf.define(CAMEL_SOURCE_KAFKABATCHAPICURIOREGISTRYNOTSECUREDSOURCE_KAMELET_BATCH_SIZE_CONF, ConfigDef.Type.INT, CAMEL_SOURCE_KAFKABATCHAPICURIOREGISTRYNOTSECUREDSOURCE_KAMELET_BATCH_SIZE_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_KAFKABATCHAPICURIOREGISTRYNOTSECUREDSOURCE_KAMELET_BATCH_SIZE_DOC);
         conf.define(CAMEL_SOURCE_KAFKABATCHAPICURIOREGISTRYNOTSECUREDSOURCE_KAMELET_POLL_TIMEOUT_CONF, ConfigDef.Type.INT, CAMEL_SOURCE_KAFKABATCHAPICURIOREGISTRYNOTSECUREDSOURCE_KAMELET_POLL_TIMEOUT_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_KAFKABATCHAPICURIOREGISTRYNOTSECUREDSOURCE_KAMELET_POLL_TIMEOUT_DOC);
         conf.define(CAMEL_SOURCE_KAFKABATCHAPICURIOREGISTRYNOTSECUREDSOURCE_KAMELET_MAX_POLL_INTERVAL_MS_CONF, ConfigDef.Type.INT, CAMEL_SOURCE_KAFKABATCHAPICURIOREGISTRYNOTSECUREDSOURCE_KAMELET_MAX_POLL_INTERVAL_MS_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_KAFKABATCHAPICURIOREGISTRYNOTSECUREDSOURCE_KAMELET_MAX_POLL_INTERVAL_MS_DOC);
+        conf.define(CAMEL_SOURCE_KAFKABATCHAPICURIOREGISTRYNOTSECUREDSOURCE_KAMELET_BATCHING_INTERVAL_MS_CONF, ConfigDef.Type.INT, CAMEL_SOURCE_KAFKABATCHAPICURIOREGISTRYNOTSECUREDSOURCE_KAMELET_BATCHING_INTERVAL_MS_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_KAFKABATCHAPICURIOREGISTRYNOTSECUREDSOURCE_KAMELET_BATCHING_INTERVAL_MS_DOC);
         conf.define(CAMEL_SOURCE_KAFKABATCHAPICURIOREGISTRYNOTSECUREDSOURCE_KAMELET_TOPIC_IS_PATTERN_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SOURCE_KAFKABATCHAPICURIOREGISTRYNOTSECUREDSOURCE_KAMELET_TOPIC_IS_PATTERN_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_KAFKABATCHAPICURIOREGISTRYNOTSECUREDSOURCE_KAMELET_TOPIC_IS_PATTERN_DOC);
         return conf;
     }

diff --git a/...src/main/resources/kamelets/kafka-batch-apicurio-registry-not-secured-source.kamelet.yaml b/...src/main/resources/kamelets/kafka-batch-apicurio-registry-not-secured-source.kamelet.yaml
@@ -119,6 +119,10 @@ spec:
         title: Max Poll Interval
         description: The maximum delay between invocations of poll() when using consumer group management
         type: int
+      batchingIntervalMs:
+        title: Batching Interval
+        description: In consumer batching mode, then this option is specifying a time in millis, to trigger batch completion eager when the current batch size has not reached the maximum size defined by maxPollRecords. Notice the trigger is not exact at the given interval, as this can only happen between kafka polls (see pollTimeoutMs option).
+        type: int
       topicIsPattern:
         title: Topic Is Pattern
         description: Whether the topic is a pattern (regular expression). This can be used to subscribe to dynamic number of topics matching the pattern.
@@ -128,7 +132,7 @@ spec:
     - "camel:kafka"
     - "camel:core"
     - "camel:kamelet"
-    - "mvn:io.quarkus:quarkus-apicurio-registry-avro:3.6.3"
+    - "mvn:io.quarkus:quarkus-apicurio-registry-avro:3.18.1"
   template:
     beans:
       - name: kafkaHeaderDeserializer
@@ -152,6 +156,7 @@ spec:
         maxPollRecords: "{{batchSize}}"
         pollTimeoutMs: "{{pollTimeout}}"
         maxPollIntervalMs: "{{?maxPollIntervalMs}}"
+        batchingIntervalMs: "{{?batchingIntervalMs}}"
         batching: true
         kafkaManualCommitFactory: "#bean:{{manualCommitFactory}}"
         topicIsPattern: "{{topicIsPattern}}"

diff --git a/connectors/camel-kafka-batch-apicurio-registry-source-kafka-connector/pom.xml b/connectors/camel-kafka-batch-apicurio-registry-source-kafka-connector/pom.xml
@@ -49,6 +49,11 @@
       <groupId>org.apache.camel.kafkaconnector</groupId>
       <artifactId>camel-kafka-connector</artifactId>
     </dependency>
+    <dependency>
+      <groupId>io.quarkus</groupId>
+      <artifactId>quarkus-apicurio-registry-avro</artifactId>
+      <version>3.18.1</version>
+    </dependency>
     <dependency>
       <groupId>org.apache.camel</groupId>
       <artifactId>camel-kafka</artifactId>
@@ -61,11 +66,6 @@
       <groupId>org.apache.camel</groupId>
       <artifactId>camel-kamelet</artifactId>
     </dependency>
-    <dependency>
-      <groupId>io.quarkus</groupId>
-      <artifactId>quarkus-apicurio-registry-avro</artifactId>
-      <version>3.6.3</version>
-    </dependency>
     <!--END OF GENERATED CODE-->
   </dependencies>
   <build>

diff --git a/...-connector/src/generated/resources/camel-kafka-batch-apicurio-registry-source-source.json b/...-connector/src/generated/resources/camel-kafka-batch-apicurio-registry-source-source.json
@@ -102,6 +102,12 @@
 			"priority": "MEDIUM",
 			"required": "false"
 		},
+		"camel.kamelet.kafka-batch-apicurio-registry-source.batchingIntervalMs": {
+			"name": "camel.kamelet.kafka-batch-apicurio-registry-source.batchingIntervalMs",
+			"description": "In consumer batching mode, then this option is specifying a time in millis, to trigger batch completion eager when the current batch size has not reached the maximum size defined by maxPollRecords. Notice the trigger is not exact at the given interval, as this can only happen between kafka polls (see pollTimeoutMs option).",
+			"priority": "MEDIUM",
+			"required": "false"
+		},
 		"camel.kamelet.kafka-batch-apicurio-registry-source.apicurioAuthServiceUrl": {
 			"name": "camel.kamelet.kafka-batch-apicurio-registry-source.apicurioAuthServiceUrl",
 			"description": "The URL for Keycloak instance securing the Apicurio Registry Example: http:\/\/my-keycloak.com:8080\/",