指定ksqlDB使用者的偏移量

问题描述

可以通过以下方式更改新使用者的默认偏移量

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

我想知道是否可以像普通kafka消费者一样通过时间戳指定偏移量？

解决方法

据我所知，目前这是不可能的。

您始终可以按消息的时间戳进行过滤（默认情况下为ROWTIME），并使用WHERE应用过滤条件。