Auto.offset.Reset Default для Spring Kafka ⇐ JAVA

[Anonymous]

Док ясно говорит, что auto.offset.reset по умолчанию по последним .

Код: Выделить всё

auto.offset.reset

: определяет поведение потребителя, когда не существует совершенной позиции (которая происходит, когда группа сначала инициализируется) или когда смещение выходит за пределы диапазона. Вы можете выбрать либо сбросить позицию в «Самое раннее» смещение, либо «последнее» смещение ( по умолчанию ).
потребитель Kafka для Confluent Platform

. PrettyPrint-Override "> @Bean
public ConsumerFactory consumerFactory() {
Map props = new HashMap();
props.put(
ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG,
bootstrapAddress);
props.put(ConsumerConfig.GROUP_ID_CONFIG, "1");
props.put(
ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG,
StringDeserializer.class);
props.put(
ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG,
JsonDeserializer.class);
return new DefaultKafkaConsumerFactory(
props,
new StringDeserializer(),
new JsonDeserializer(User.class));
}
< /code>


org.springframework.kafka
spring-kafka

< /code>
, кажется, обеспечивает использование даже старых сообщений. Я запустил свой сервер почти через неделю после того, как сообщение было произведено (чуть ниже TTL по умолчанию). Я не могу поверить, что весна будет переопределить нативные значения по умолчанию Кафки.>

Подробнее здесь: https://stackoverflow.com/questions/796 ... ring-kafka