You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2024/02/02 13:21:34 UTC
(camel-kamelets) branch kafka-maxInterval created (now 824c6678)
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a change to branch kafka-maxInterval
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
at 824c6678 Kafka Batch SSL: Expose also maxPollIntervalMs option
This branch includes the following new commits:
new 73464f34 Kafka Batch Apicurio Not Secured Source: Expose also maxPollIntervalMs option
new 8d189eca Kafka Batch Apicurio Not Secured Source: Expose also maxPollIntervalMs option
new af418be7 Kafka Batch Azure Source: Expose also maxPollIntervalMs option
new a68cfc0d Kafka Batch Azure Source: Expose also maxPollIntervalMs option
new 16768af6 Kafka Batch Scram Source: Expose also maxPollIntervalMs option
new 75420c06 Kafka Batch Scram Source: Expose also maxPollIntervalMs option
new 72dcae61 Kafka Batch Source: Expose also maxPollIntervalMs option
new 090c9f06 Kafka Batch Source: Expose also maxPollIntervalMs option
new 47093120 Kafka Batch SSL: Expose also maxPollIntervalMs option
new 824c6678 Kafka Batch SSL: Expose also maxPollIntervalMs option
The 10 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
(camel-kamelets) 10/10: Kafka Batch SSL: Expose also maxPollIntervalMs option
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch kafka-maxInterval
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 824c6678dc96ef0dddf3b5b4df1ff71cab5c3585
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri Feb 2 14:20:59 2024 +0100
Kafka Batch SSL: Expose also maxPollIntervalMs option
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
.../src/main/resources/kamelets/kafka-batch-ssl-source.kamelet.yaml | 5 +++++
1 file changed, 5 insertions(+)
diff --git a/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-ssl-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-ssl-source.kamelet.yaml
index 5d6f4ad8..1c2dd340 100644
--- a/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-ssl-source.kamelet.yaml
+++ b/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-ssl-source.kamelet.yaml
@@ -152,6 +152,10 @@ spec:
description: The timeout used when polling the KafkaConsumer
type: int
default: 5000
+ maxPollIntervalMs:
+ title: Max Poll Interval
+ description: The maximum delay between invocations of poll() when using consumer group management
+ type: int
dependencies:
- "mvn:org.apache.camel.kamelets:camel-kamelets-utils:4.4.0-SNAPSHOT"
- "camel:core"
@@ -183,6 +187,7 @@ spec:
saslJaasConfig: '{{?saslJaasConfig}}'
maxPollRecords: "{{batchSize}}"
pollTimeoutMs: "{{pollTimeout}}"
+ maxPollIntervalMs: "{{?maxPollIntervalMs}}"
batching: true
kafkaManualCommitFactory: "#bean:{{manualCommitFactory}}"
type: '#class:org.apache.camel.component.kafka.KafkaConfiguration'
(camel-kamelets) 02/10: Kafka Batch Apicurio Not Secured Source: Expose also maxPollIntervalMs option
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch kafka-maxInterval
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 8d189ecac588e5f88c9c11b20bbc0b03a1df50ab
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri Feb 2 14:11:38 2024 +0100
Kafka Batch Apicurio Not Secured Source: Expose also maxPollIntervalMs option
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
.../kafka-batch-apicurio-registry-not-secured-source.kamelet.yaml | 5 +++++
1 file changed, 5 insertions(+)
diff --git a/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-apicurio-registry-not-secured-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-apicurio-registry-not-secured-source.kamelet.yaml
index 7b4c787a..0e5e43c3 100644
--- a/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-apicurio-registry-not-secured-source.kamelet.yaml
+++ b/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-apicurio-registry-not-secured-source.kamelet.yaml
@@ -115,6 +115,10 @@ spec:
description: The timeout used when polling the KafkaConsumer
type: int
default: 5000
+ maxPollIntervalMs:
+ title: Max Poll Interval
+ description: The maximum delay between invocations of poll() when using consumer group management
+ type: int
dependencies:
- "mvn:org.apache.camel.kamelets:camel-kamelets-utils:4.4.0-SNAPSHOT"
- "camel:kafka"
@@ -143,6 +147,7 @@ spec:
additionalProperties.apicurio.registry.avro-datum-provider: "{{avroDatumProvider}}"
maxPollRecords: "{{batchSize}}"
pollTimeoutMs: "{{pollTimeout}}"
+ maxPollIntervalMs: "{{?maxPollIntervalMs}}"
batching: true
kafkaManualCommitFactory: "#bean:{{manualCommitFactory}}"
steps:
(camel-kamelets) 09/10: Kafka Batch SSL: Expose also maxPollIntervalMs option
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch kafka-maxInterval
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 47093120a5831c823522212d2cfaa76e9c3d492b
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri Feb 2 14:18:11 2024 +0100
Kafka Batch SSL: Expose also maxPollIntervalMs option
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
kamelets/kafka-batch-ssl-source.kamelet.yaml | 5 +++++
1 file changed, 5 insertions(+)
diff --git a/kamelets/kafka-batch-ssl-source.kamelet.yaml b/kamelets/kafka-batch-ssl-source.kamelet.yaml
index 5d6f4ad8..1c2dd340 100644
--- a/kamelets/kafka-batch-ssl-source.kamelet.yaml
+++ b/kamelets/kafka-batch-ssl-source.kamelet.yaml
@@ -152,6 +152,10 @@ spec:
description: The timeout used when polling the KafkaConsumer
type: int
default: 5000
+ maxPollIntervalMs:
+ title: Max Poll Interval
+ description: The maximum delay between invocations of poll() when using consumer group management
+ type: int
dependencies:
- "mvn:org.apache.camel.kamelets:camel-kamelets-utils:4.4.0-SNAPSHOT"
- "camel:core"
@@ -183,6 +187,7 @@ spec:
saslJaasConfig: '{{?saslJaasConfig}}'
maxPollRecords: "{{batchSize}}"
pollTimeoutMs: "{{pollTimeout}}"
+ maxPollIntervalMs: "{{?maxPollIntervalMs}}"
batching: true
kafkaManualCommitFactory: "#bean:{{manualCommitFactory}}"
type: '#class:org.apache.camel.component.kafka.KafkaConfiguration'
(camel-kamelets) 06/10: Kafka Batch Scram Source: Expose also maxPollIntervalMs option
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch kafka-maxInterval
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 75420c067b33eeb39941621b1c459cb8678cc377
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri Feb 2 14:14:29 2024 +0100
Kafka Batch Scram Source: Expose also maxPollIntervalMs option
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
.../main/resources/kamelets/kafka-batch-scram-source.kamelet.yaml | 5 +++++
1 file changed, 5 insertions(+)
diff --git a/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-scram-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-scram-source.kamelet.yaml
index 0d5e6580..3a07972e 100644
--- a/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-scram-source.kamelet.yaml
+++ b/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-scram-source.kamelet.yaml
@@ -128,6 +128,10 @@ spec:
description: The timeout used when polling the KafkaConsumer
type: int
default: 5000
+ maxPollIntervalMs:
+ title: Max Poll Interval
+ description: The maximum delay between invocations of poll() when using consumer group management
+ type: int
dependencies:
- "mvn:org.apache.camel.kamelets:camel-kamelets-utils:4.4.0-SNAPSHOT"
- "camel:core"
@@ -155,6 +159,7 @@ spec:
groupId: "{{?consumerGroup}}"
maxPollRecords: "{{batchSize}}"
pollTimeoutMs: "{{pollTimeout}}"
+ maxPollIntervalMs: "{{?maxPollIntervalMs}}"
batching: true
kafkaManualCommitFactory: "#bean:{{manualCommitFactory}}"
steps:
(camel-kamelets) 05/10: Kafka Batch Scram Source: Expose also maxPollIntervalMs option
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch kafka-maxInterval
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 16768af6102ac5f98d6084232ecfa623d8e2b63e
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri Feb 2 14:13:59 2024 +0100
Kafka Batch Scram Source: Expose also maxPollIntervalMs option
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
kamelets/kafka-batch-scram-source.kamelet.yaml | 5 +++++
1 file changed, 5 insertions(+)
diff --git a/kamelets/kafka-batch-scram-source.kamelet.yaml b/kamelets/kafka-batch-scram-source.kamelet.yaml
index 0d5e6580..3a07972e 100644
--- a/kamelets/kafka-batch-scram-source.kamelet.yaml
+++ b/kamelets/kafka-batch-scram-source.kamelet.yaml
@@ -128,6 +128,10 @@ spec:
description: The timeout used when polling the KafkaConsumer
type: int
default: 5000
+ maxPollIntervalMs:
+ title: Max Poll Interval
+ description: The maximum delay between invocations of poll() when using consumer group management
+ type: int
dependencies:
- "mvn:org.apache.camel.kamelets:camel-kamelets-utils:4.4.0-SNAPSHOT"
- "camel:core"
@@ -155,6 +159,7 @@ spec:
groupId: "{{?consumerGroup}}"
maxPollRecords: "{{batchSize}}"
pollTimeoutMs: "{{pollTimeout}}"
+ maxPollIntervalMs: "{{?maxPollIntervalMs}}"
batching: true
kafkaManualCommitFactory: "#bean:{{manualCommitFactory}}"
steps:
(camel-kamelets) 07/10: Kafka Batch Source: Expose also maxPollIntervalMs option
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch kafka-maxInterval
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 72dcae61657428b694129a3379411f69455f52e1
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri Feb 2 14:15:17 2024 +0100
Kafka Batch Source: Expose also maxPollIntervalMs option
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
kamelets/kafka-batch-source.kamelet.yaml | 5 +++++
1 file changed, 5 insertions(+)
diff --git a/kamelets/kafka-batch-source.kamelet.yaml b/kamelets/kafka-batch-source.kamelet.yaml
index 853e05bb..1e952363 100644
--- a/kamelets/kafka-batch-source.kamelet.yaml
+++ b/kamelets/kafka-batch-source.kamelet.yaml
@@ -128,6 +128,10 @@ spec:
description: The timeout used when polling the KafkaConsumer
type: int
default: 5000
+ maxPollIntervalMs:
+ title: Max Poll Interval
+ description: The maximum delay between invocations of poll() when using consumer group management
+ type: int
dependencies:
- "mvn:org.apache.camel.kamelets:camel-kamelets-utils:4.4.0-SNAPSHOT"
- "camel:core"
@@ -155,6 +159,7 @@ spec:
groupId: "{{?consumerGroup}}"
maxPollRecords: "{{batchSize}}"
pollTimeoutMs: "{{pollTimeout}}"
+ maxPollIntervalMs: "{{?maxPollIntervalMs}}"
batching: true
kafkaManualCommitFactory: "#bean:{{manualCommitFactory}}"
steps:
(camel-kamelets) 04/10: Kafka Batch Azure Source: Expose also maxPollIntervalMs option
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch kafka-maxInterval
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit a68cfc0dcba6f37091b6218e371f98466bcdd111
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri Feb 2 14:13:07 2024 +0100
Kafka Batch Azure Source: Expose also maxPollIntervalMs option
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
.../kamelets/kafka-batch-azure-schema-registry-source.kamelet.yaml | 5 +++++
1 file changed, 5 insertions(+)
diff --git a/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-azure-schema-registry-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-azure-schema-registry-source.kamelet.yaml
index a83ad6ed..82d21574 100644
--- a/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-azure-schema-registry-source.kamelet.yaml
+++ b/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-azure-schema-registry-source.kamelet.yaml
@@ -135,6 +135,10 @@ spec:
description: The timeout used when polling the KafkaConsumer
type: int
default: 5000
+ maxPollIntervalMs:
+ title: Max Poll Interval
+ description: The maximum delay between invocations of poll() when using consumer group management
+ type: int
dependencies:
- "mvn:org.apache.camel.kamelets:camel-kamelets-utils:4.4.0-SNAPSHOT"
- "camel:kafka"
@@ -169,6 +173,7 @@ spec:
valueDeserializer: "{{valueDeserializer}}"
maxPollRecords: "{{batchSize}}"
pollTimeoutMs: "{{pollTimeout}}"
+ maxPollIntervalMs: "{{?maxPollIntervalMs}}"
batching: true
kafkaManualCommitFactory: "#bean:{{manualCommitFactory}}"
additionalProperties.schema.registry.url: "{{azureRegistryUrl}}"
(camel-kamelets) 01/10: Kafka Batch Apicurio Not Secured Source: Expose also maxPollIntervalMs option
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch kafka-maxInterval
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 73464f34564e2d0a745a7b6818401a79fa1674b1
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri Feb 2 14:10:55 2024 +0100
Kafka Batch Apicurio Not Secured Source: Expose also maxPollIntervalMs option
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
.../kafka-batch-apicurio-registry-not-secured-source.kamelet.yaml | 5 +++++
1 file changed, 5 insertions(+)
diff --git a/kamelets/kafka-batch-apicurio-registry-not-secured-source.kamelet.yaml b/kamelets/kafka-batch-apicurio-registry-not-secured-source.kamelet.yaml
index 7b4c787a..0e5e43c3 100644
--- a/kamelets/kafka-batch-apicurio-registry-not-secured-source.kamelet.yaml
+++ b/kamelets/kafka-batch-apicurio-registry-not-secured-source.kamelet.yaml
@@ -115,6 +115,10 @@ spec:
description: The timeout used when polling the KafkaConsumer
type: int
default: 5000
+ maxPollIntervalMs:
+ title: Max Poll Interval
+ description: The maximum delay between invocations of poll() when using consumer group management
+ type: int
dependencies:
- "mvn:org.apache.camel.kamelets:camel-kamelets-utils:4.4.0-SNAPSHOT"
- "camel:kafka"
@@ -143,6 +147,7 @@ spec:
additionalProperties.apicurio.registry.avro-datum-provider: "{{avroDatumProvider}}"
maxPollRecords: "{{batchSize}}"
pollTimeoutMs: "{{pollTimeout}}"
+ maxPollIntervalMs: "{{?maxPollIntervalMs}}"
batching: true
kafkaManualCommitFactory: "#bean:{{manualCommitFactory}}"
steps:
(camel-kamelets) 03/10: Kafka Batch Azure Source: Expose also maxPollIntervalMs option
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch kafka-maxInterval
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit af418be784afac060dcd1bee0b3d4b1984f76335
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri Feb 2 14:12:30 2024 +0100
Kafka Batch Azure Source: Expose also maxPollIntervalMs option
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
kamelets/kafka-batch-azure-schema-registry-source.kamelet.yaml | 5 +++++
1 file changed, 5 insertions(+)
diff --git a/kamelets/kafka-batch-azure-schema-registry-source.kamelet.yaml b/kamelets/kafka-batch-azure-schema-registry-source.kamelet.yaml
index a83ad6ed..82d21574 100644
--- a/kamelets/kafka-batch-azure-schema-registry-source.kamelet.yaml
+++ b/kamelets/kafka-batch-azure-schema-registry-source.kamelet.yaml
@@ -135,6 +135,10 @@ spec:
description: The timeout used when polling the KafkaConsumer
type: int
default: 5000
+ maxPollIntervalMs:
+ title: Max Poll Interval
+ description: The maximum delay between invocations of poll() when using consumer group management
+ type: int
dependencies:
- "mvn:org.apache.camel.kamelets:camel-kamelets-utils:4.4.0-SNAPSHOT"
- "camel:kafka"
@@ -169,6 +173,7 @@ spec:
valueDeserializer: "{{valueDeserializer}}"
maxPollRecords: "{{batchSize}}"
pollTimeoutMs: "{{pollTimeout}}"
+ maxPollIntervalMs: "{{?maxPollIntervalMs}}"
batching: true
kafkaManualCommitFactory: "#bean:{{manualCommitFactory}}"
additionalProperties.schema.registry.url: "{{azureRegistryUrl}}"
(camel-kamelets) 08/10: Kafka Batch Source: Expose also maxPollIntervalMs option
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch kafka-maxInterval
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 090c9f06570957280af3c987049f17c1c58b3d7b
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri Feb 2 14:16:07 2024 +0100
Kafka Batch Source: Expose also maxPollIntervalMs option
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
.../src/main/resources/kamelets/kafka-batch-source.kamelet.yaml | 5 +++++
1 file changed, 5 insertions(+)
diff --git a/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-source.kamelet.yaml
index 853e05bb..1e952363 100644
--- a/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-source.kamelet.yaml
+++ b/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-source.kamelet.yaml
@@ -128,6 +128,10 @@ spec:
description: The timeout used when polling the KafkaConsumer
type: int
default: 5000
+ maxPollIntervalMs:
+ title: Max Poll Interval
+ description: The maximum delay between invocations of poll() when using consumer group management
+ type: int
dependencies:
- "mvn:org.apache.camel.kamelets:camel-kamelets-utils:4.4.0-SNAPSHOT"
- "camel:core"
@@ -155,6 +159,7 @@ spec:
groupId: "{{?consumerGroup}}"
maxPollRecords: "{{batchSize}}"
pollTimeoutMs: "{{pollTimeout}}"
+ maxPollIntervalMs: "{{?maxPollIntervalMs}}"
batching: true
kafkaManualCommitFactory: "#bean:{{manualCommitFactory}}"
steps: