From f0da6daed4709ad9c3aef68ea817f792c320a104 Mon Sep 17 00:00:00 2001 From: dmccoystephenson Date: Wed, 19 Jun 2024 15:05:31 -0600 Subject: [PATCH] Changed default value for enable.auto.commit property to 'true' --- sample.env | 2 +- .../java/us/dot/its/jpo/ode/aws/depositor/AwsDepositor.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/sample.env b/sample.env index a7f202e..884afc6 100644 --- 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 index d85a2d4..1f62e90 100644 --- 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);