diff --git a/jpo-conflictvisualizer-api/src/main/java/us/dot/its/jpo/ode/api/ConflictMonitorApiProperties.java b/jpo-conflictvisualizer-api/src/main/java/us/dot/its/jpo/ode/api/ConflictMonitorApiProperties.java index 415497a80..a47cbd8fa 100644 --- a/jpo-conflictvisualizer-api/src/main/java/us/dot/its/jpo/ode/api/ConflictMonitorApiProperties.java +++ b/jpo-conflictvisualizer-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 index ad0671e6e..f78580c21 100644 --- 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 \ No newline at end of file