每次使用ksql查询ktable时获取所有行

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

我想使用ksql对kafka进行restapi调用,每次都从ktable获取所有行。从ktable获取所有行的最佳方法是什么?
当我为ktable正在侦听的主题生成消息(exp:key='1')时,我只接收给定键上的聚合。我应该对web服务的每个请求进行什么查询以读取表中的所有行?

czq61nw1

czq61nw11#

你需要 SET 'auto.offset.reset' = 'earliest' 在select查询语句之前。

相关问题