Changed default value for enable.auto.commit property to 'true'

CDOT-CV · Jun 19, 2024 · f0da6da · f0da6da
1 parent b4d6411
commit f0da6da
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/sample.env b/sample.env
@@ -15,7 +15,7 @@ HEADER_X_API_KEY=
 KAFKA_TYPE=
 CONFLUENT_KEY=
 CONFLUENT_SECRET=
-# Defaults to false
+# Defaults to true
 KAFKA_ENABLE_AUTO_COMMIT= 
 # Defaults to 1000
 KAFKA_AUTO_COMMIT_INTERVAL_MS= 

diff --git a/src/main/java/us/dot/its/jpo/ode/aws/depositor/AwsDepositor.java b/src/main/java/us/dot/its/jpo/ode/aws/depositor/AwsDepositor.java
@@ -159,7 +159,7 @@ public void run(String[] args) throws Exception {
 		}
 
 		KAFKA_AUTO_COMMIT_INTERVAL_MS = getEnvironmentVariable("KAFKA_AUTO_COMMIT_INTERVAL_MS", "1000");
-		KAFKA_ENABLE_AUTO_COMMIT = getEnvironmentVariable("KAFKA_ENABLE_AUTO_COMMIT", "false");
+		KAFKA_ENABLE_AUTO_COMMIT = getEnvironmentVariable("KAFKA_ENABLE_AUTO_COMMIT", "true");
 		KAFKA_SESSION_TIMEOUT_MS = getEnvironmentVariable("KAFKA_SESSION_TIMEOUT_MS", "30000");
 
 		props.put("group.id", group);