有可能改变新消费者的违约补偿
SET 'auto.offset.reset'='earliest';
我想知道,是否有可能指定像普通Kafka消费者的时间戳偏移?
fkvaft9z1#
据我所知,这目前是不可能的。您可以始终按消息的时间戳进行筛选(默认情况下: ROWTIME )并使用 WHERE .
ROWTIME
WHERE
1条答案
按热度按时间fkvaft9z1#
据我所知,这目前是不可能的。
您可以始终按消息的时间戳进行筛选(默认情况下:
ROWTIME
)并使用WHERE
.