From d2f74d7bbbc3df86bd5204e5efd6a34ab3055446 Mon Sep 17 00:00:00 2001
From: Andrea Cavalli <andrea@cavallium.it>
Date: Thu, 28 Jul 2022 23:40:26 +0200
Subject: [PATCH] Update commit batch size

---
 src/main/java/it/tdlight/reactiveapi/KafkaConsumer.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/main/java/it/tdlight/reactiveapi/KafkaConsumer.java b/src/main/java/it/tdlight/reactiveapi/KafkaConsumer.java
index 3590ae7..cc20c77 100644
--- 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;