add kafkaConsumersAlwaysOn config

CDOT-CV · Dec 18, 2024 · 79b6fea · 79b6fea
1 parent 62e22e7
commit 79b6fea
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 0 deletions.
diff --git a/...lictvisualizer-api/src/main/java/us/dot/its/jpo/ode/api/ConflictMonitorApiProperties.java b/...lictvisualizer-api/src/main/java/us/dot/its/jpo/ode/api/ConflictMonitorApiProperties.java
@@ -57,6 +57,10 @@
 @ConfigurationProperties("conflict.monitor.api")
 public class ConflictMonitorApiProperties {
 
+    @Getter
+    @Setter
+    private boolean kafkaConsumersAlwaysOn;
+
     private static int maximumResponseSize;
     private static String cors;
     private static final Logger logger = LoggerFactory.getLogger(ConflictMonitorApiProperties.class);

diff --git a/jpo-conflictvisualizer-api/src/main/resources/application.yaml b/jpo-conflictvisualizer-api/src/main/resources/application.yaml
@@ -37,3 +37,7 @@ kafka.topics:
       cleanupPolicy: delete
       retentionMs: 300000
 
+conflict:
+  monitor:
+    api:
+      kafka-consumers-always-on: false