Как читать сообщения, имеющие метку времени больше, чем данная метка времени из темы Кафки

Question

Я вижу много ответов об использовании offsetsForTimes. Разве я не могу просто прочитать сообщения, которые имеют временную метку, превышающую заданную временную метку, вместо того, чтобы идти на offsetsForTimes. Что-то вроде ниже

            consumerRecords.forEach(record -> {
            if (record.timestamp() > startTimestamp) {

// обрабатывать только эти записи

Зачем мне использовать offsetsForTimes?

Answer 1

Можно. Но в Kafka есть индекс, основанный на отметках времени, поэтому вы можете легко разместить получателя на первое сообщение, отметка времени которого больше указанной.