我想使用ksql对kafka进行restapi调用,每次都从ktable获取所有行。从ktable获取所有行的最佳方法是什么?当我为ktable正在侦听的主题生成消息(exp:key='1')时,我只接收给定键上的聚合。我应该对web服务的每个请求进行什么查询以读取表中的所有行?
czq61nw11#
你需要 SET 'auto.offset.reset' = 'earliest' 在select查询语句之前。
SET 'auto.offset.reset' = 'earliest'
1条答案
按热度按时间czq61nw11#
你需要
SET 'auto.offset.reset' = 'earliest'
在select查询语句之前。