指定ksqldb使用者的偏移量

sauutmhj  于 2021-06-04  发布在  Kafka
关注(0)|答案(1)|浏览(366)

有可能改变新消费者的违约补偿

SET 'auto.offset.reset'='earliest';

我想知道,是否有可能指定像普通Kafka消费者的时间戳偏移?

fkvaft9z

fkvaft9z1#

据我所知,这目前是不可能的。
您可以始终按消息的时间戳进行筛选(默认情况下: ROWTIME )并使用 WHERE .

相关问题