【发布时间】：2018-12-12 18:20:13
【问题描述】：
我知道使用 Kafka 消费者的 api 我们可以获得与特定时间戳相对应的偏移量 (getOffsetsByTimes())。
我们如何获取偏移量并从基于 KSQL 或 KSTream 中的时间戳的点开始重播流？
【问题讨论】：
标签： apache-kafka kafka-consumer-api apache-kafka-streams ksqldb
【发布时间】：2018-12-12 18:20:13
【问题描述】：
这在 KSQL 中尚不支持。您有一个选择是使用谓词过滤掉您不想要的记录：
SELECT * FROM SOURCE_STREAM WHERE ROWTIME > xxxx
但这可能效率低下，具体取决于偏移量相对于日志中数据量的位置。
【讨论】：
-
"yet" -- 有问题要看吗？