SUPPORT-9122:fixes

2025-04-24 12:04:44 +03:00 · 2025-04-24 12:04:44 +03:00 · 87c3995070
commit 87c3995070
parent 87da2515c3
1 changed files with 1 additions and 1 deletions
--- a/backend/src/main/java/ervu_business_metrics/kafka/KafkaConfig.java
+++ b/backend/src/main/java/ervu_business_metrics/kafka/KafkaConfig.java
@ -58,7 +58,7 @@ public class KafkaConfig {
    props.put(SaslConfigs.SASL_JAAS_CONFIG, loginModule + " required username=\""
                                            + username + "\" password=\"" + password + "\";");
    props.put(SaslConfigs.SASL_MECHANISM, saslMechanism);
-
+    props.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "latest");
    return props;
  }