Skip to content

Commit

Permalink
Support Kafka Batch as Kamelet source - Kafka Not Secured Source as b…
Browse files Browse the repository at this point in the history
…atch

Signed-off-by: Andrea Cosentino <ancosen@gmail.com>
  • Loading branch information
oscerd committed Jan 30, 2024
1 parent 9be1caa commit 148c476
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 2 deletions.
2 changes: 2 additions & 0 deletions docs/modules/ROOT/nav.adoc
Original file line number Diff line number Diff line change
Expand Up @@ -131,6 +131,8 @@
* xref:kafka-apicurio-registry-not-secured-source.adoc[]
* xref:kafka-azure-schema-registry-sink.adoc[]
* xref:kafka-azure-schema-registry-source.adoc[]
* xref:kafka-batch-manual-commit-action.adoc[]
* xref:kafka-batch-not-secured-source.adoc[]
* xref:kafka-manual-commit-action.adoc[]
* xref:kafka-not-secured-sink.adoc[]
* xref:kafka-not-secured-source.adoc[]
Expand Down
4 changes: 2 additions & 2 deletions kamelets/kafka-batch-not-secured-source.kamelet.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -88,12 +88,12 @@ spec:
type: boolean
default: true
batchSize:
title: The batch dimension
title: Batch Dimension
description: The maximum number of records returned in a single call to poll()
type: int
default: 500
pollTimeout:
title: The poll timeout interval
title: Poll Timeout Interval
description: The timeout used when polling the KafkaConsumer
type: int
default: 5000
Expand Down

0 comments on commit 148c476

Please sign in to comment.