Added zstd compression to conflict visualizer api

CDOT-CV · Oct 23, 2024 · 9753d0a · 9753d0a
1 parent fd8fcdb
commit 9753d0a
Showing 1 changed file with 4 additions and 1 deletion.
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
@@ -380,7 +380,10 @@ public Properties createStreamProperties(String name) {
         streamProps.put(ProducerConfig.DELIVERY_TIMEOUT_MS_CONFIG, FIVE_MINUTES_MS);
 
         // Disable batching
-        streamProps.put(ProducerConfig.BATCH_SIZE_CONFIG, 0);
+        // streamProps.put(ProducerConfig.BATCH_SIZE_CONFIG, 0);
+
+        streamProps.put(ProducerConfig.COMPRESSION_TYPE_CONFIG, "zstd");
+        streamProps.put(ProducerConfig.LINGER_MS_CONFIG, 50);
 
         if (confluentCloudEnabled) {
             streamProps.put("ssl.endpoint.identification.algorithm", "https");