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

Question

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

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

Answer 1

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

SELECT * FROM SOURCE_STREAM WHERE ROWTIME > xxxx

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