每次使用 KSql 查询 KTable 时获取所有行

Question

我想使用 Ksql 对 Kafka 进行 rest api 调用，并且每次都从 Ktable 中获取所有行。 从 KTable 获取所有行的最佳方法是什么？

当我为 Ktable 正在侦听的主题生成消息 (exp: Key = '1') 时，我只收到给定键的聚合。我应该对 Web 服务的每个请求进行什么查询以读取表中的所有行？

Answer 1

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