Встречается на 2% собеседований по Java

Что такое earliest смещение консьюмера в Kafka

Earliest offset (auto.offset.reset=earliest) в Kafka означает, что консьюмер начнет чтение с самого старого доступного сообщения в партиции, если у него нет сохраненного смещения (offset). Это полезно, например, при первом запуске консьюмера или при чтении с нового топика.

Пример настройки консьюмера:

java
Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("group.id", "test-group");
props.put("auto.offset.reset", "earliest"); // читать с начала
props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
props.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");

KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
consumer.subscribe(Collections.singletonList("my-topic"));

text

Важно: если у консьюмера уже есть сохраненный offset (например, в `__consumer_offsets`), он будет использовать его, а не earliest. Это поведение отличается от `auto.offset.reset=latest`, где консьюмер начинает читать только новые сообщения.
Sophi
Софи собрала все вопросы. Тренируйся и получай
офферы быстрее!
Попробовать бесплатноArrow

Следующий вопрос

Это единственный вопрос по вашему фильтру

как отвечать на вопрос
пример собеседования
фреймворки на собеседовании
типичные вопросы junior
интервью вопросы и ответы