Skip to content

Commit

Permalink
Kafka Batch Not Secured Source: Expose also maxPollIntervalMs option
Browse files Browse the repository at this point in the history
Signed-off-by: Andrea Cosentino <ancosen@gmail.com>
  • Loading branch information
oscerd committed Feb 2, 2024
1 parent e1ed999 commit e534f2f
Showing 1 changed file with 5 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -97,6 +97,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"
Expand All @@ -121,6 +125,7 @@ spec:
groupId: "{{?consumerGroup}}"
maxPollRecords: "{{batchSize}}"
pollTimeoutMs: "{{pollTimeout}}"
maxPollIntervalMs: "{{?maxPollIntervalMs}}"
batching: true
kafkaManualCommitFactory: "#bean:{{manualCommitFactory}}"
steps:
Expand Down

0 comments on commit e534f2f

Please sign in to comment.