.

osskit · Nov 15, 2023 · a696a7b · a696a7b
1 parent 2a06417
commit a696a7b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/java/configuration/Config.java b/src/main/java/configuration/Config.java
@@ -43,7 +43,7 @@ public static void init() throws Exception {
 
         KAFKA_BROKER = getString(dotenv, "KAFKA_BROKER");
         GROUP_ID = getString(dotenv, "GROUP_ID");
-        COMMIT_INTERVAL_MS_CONFIG = getString(dotenv, "COMMIT_INTERVAL_MS_CONFIG", "30000");
+        COMMIT_INTERVAL_MS_CONFIG = getOptionalString(dotenv, "COMMIT_INTERVAL_MS_CONFIG", "30000");
 
         // --------------------
         SOURCE_TOPIC = getString(dotenv, "SOURCE_TOPIC");