Как опросить kafka для сообщений, которые имеют метку времени менее 30 секунд?

Question

Я хочу опрашивать только записи, которые произвели менее 30 секунд. Есть ли какой-либо способ в опросе Кафки, что я могу использовать только те сообщения, которые создаются менее чем за 30 секунд?

Любые предложения или советы будут действительно полезны. Заранее спасибо.

Answer 1

Вы можете использовать метод offsetsForTimes, который возвращает смещение, отметка времени которого больше или равна заданной отметке времени. Более подробную информацию об официальном документе можно найти здесь:

https://kafka.apache.org/0101/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#offsetsForTimes(java.util.Map)

После получения смещения вы можете использовать его и начать читать с него.

https://www.programcreek.com/java-api-examples/index.php?api=org.apache.kafka.clients.consumer.OffsetAndTimestamp