set offset reset strategy

2025-02-26 17:06:03 +03:00 · 2025-02-26 17:06:03 +03:00 · b74d314932
commit b74d314932
parent 46282d6283
1 changed files with 1 additions and 0 deletions
--- a/backend/src/main/java/ru/micord/ervu/kafka/ReplyingKafkaConfig.java
+++ b/backend/src/main/java/ru/micord/ervu/kafka/ReplyingKafkaConfig.java
@ -101,6 +101,7 @@ public class ReplyingKafkaConfig {
                                                  + username + "\" password=\"" + password + "\";");
    configProps.put(SaslConfigs.SASL_MECHANISM, saslMechanism);
    configProps.put(ConsumerConfig.GROUP_ID_CONFIG, groupId + "-" + UUID.randomUUID());
+    configProps.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "latest");
    configProps.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
    return configProps;
  }