disable autocommit

NucleoTeam · Nov 16, 2023 · 083d432 · 083d432
1 parent 546bc08
commit 083d432
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/buildSrc/src/main/groovy/nucleodb.library.gradle b/buildSrc/src/main/groovy/nucleodb.library.gradle
@@ -3,7 +3,7 @@ plugins {
 }
 
 group = 'com.nucleodb'
-version = '1.10.0'
+version = '1.10.1'
 
 repositories {
     mavenCentral()

diff --git a/library/src/main/java/com/nucleocore/library/kafkaLedger/ConsumerHandler.java b/library/src/main/java/com/nucleocore/library/kafkaLedger/ConsumerHandler.java
@@ -180,8 +180,8 @@ private KafkaConsumer createConsumer(String bootstrap, String groupName) {
     props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrap);
     //System.out.println(groupName);
     props.put(ConsumerConfig.GROUP_ID_CONFIG, groupName);
-    props.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, "true");
-    props.put(ConsumerConfig.AUTO_COMMIT_INTERVAL_MS_CONFIG, 100);
+    props.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, "false");
+    //props.put(ConsumerConfig.AUTO_COMMIT_INTERVAL_MS_CONFIG, 100);
     props.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest");
     props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName());
     props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName());