|
@@ -60,7 +60,7 @@ public class KafkaProperties extends org.springframework.boot.autoconfigure.kafk
|
|
|
|
|
|
// 初始化消费者默认配置
|
|
|
this.getConsumer().setEnableAutoCommit(true);
|
|
|
- this.getConsumer().setAutoOffsetReset("earliest");
|
|
|
+ this.getConsumer().setAutoOffsetReset("latest");
|
|
|
this.getConsumer().setKeyDeserializer(StringDeserializer.class);
|
|
|
this.getConsumer().setValueDeserializer(StringDeserializer.class);
|
|
|
}
|