首页 > 解决方案 > Ksql:在 KTable 上应用过滤器生成具有空值的记录

问题描述

我想知道我在使用 ksql 时遇到的行为是否可以预期。

我从一个主题中创建了一个表,之后我创建了一个表,该表使用 where 子句选择该表的某个字段,其中一个列具有条件。

第二个表是一个持久查询。因此,我检查了输出主题,并且所有记录都在其中,要么具有空值,要么具有满足列上条件的记录的值。

但是,当我使用 select * 查询该 ktable 时,我看不到那些具有空值的记录。换句话说,从持久查询中查询 Ktable 可以得到我期望的结果。看起来很奇怪的是输出主题。为什么给我一个空值的我不需要的记录,以及我在同一主题中同时需要的记录?为什么持久查询的out topic基本上只应用了where子句,不只包含满足where子句条件的记录?

如果这是可以预料的,有没有办法解决这个问题?

标签: ksqldb

解决方案


推荐阅读