apache-kafka - KSQL/KStream - 根据生产时间获取偏移量

Question

我知道使用 Kafka 消费者的 api，我们可以获得与特定时间戳 (getOffsetsByTimes()) 对应的偏移量。

我们如何获取偏移量并从基于 KSQL 或 KSTream 中的时间戳的点开始重播流？

标签： apache-kafkakafka-consumer-apiapache-kafka-streamsksqldb

Answer 1

这在 KSQL 中尚不支持。您拥有的一种选择是使用谓词过滤掉您不想要的记录：

SELECT * FROM SOURCE_STREAM WHERE ROWTIME > xxxx

但这可能效率低下，具体取决于偏移量相对于日志中数据量的位置。