KSQL / KStream - получить смещение в соответствии со временем производства

Question

Я знаю, используя API-интерфейсы потребителей Kafka, мы можем получить смещение, соответствующее определенной временной метке (getOffsetsByTimes ()).

Как мы можем получить смещение и начать воспроизведение потоков из точки, основанной на отметке времени в KSQL или KSTream?

Answer 1

Это еще не поддерживается в KSQL.Один из вариантов, который у вас есть, - использовать предикат для фильтрации нежелательных записей:

SELECT * FROM SOURCE_STREAM WHERE ROWTIME > xxxx

, но это может быть неэффективно в зависимости от того, где смещение относительно суммыданные в журнале.