Update commit batch size

2022-07-28 23:40:26 +02:00 · 2022-07-28 23:40:26 +02:00 · d2f74d7bbb
parent fd658e5e6c
commit d2f74d7bbb
1 changed files with 1 additions and 1 deletions
--- a/src/main/java/it/tdlight/reactiveapi/KafkaConsumer.java
+++ b/src/main/java/it/tdlight/reactiveapi/KafkaConsumer.java
@ -52,7 +52,7 @@ public abstract class KafkaConsumer<K> {
 		ReceiverOptions<Integer, K> receiverOptions = ReceiverOptions
 				.<Integer, K>create(props)
 				.commitInterval(Duration.ofSeconds(10))
-				.commitBatchSize(64)
+				.commitBatchSize(65535)
 				.maxCommitAttempts(100)
 				.maxDeferredCommits(100);
 		Pattern pattern;