如何在ksqldb聚合函数中设置[ignorenulls]以不忽略null

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

我尝试通过ksqldb获取消息的最新值。因此,我使用最新的\u by \u偏移量。
文件中描述如下:
自:0.13.0
最早按偏移量(col1,earliestn,[ignorenulls])
流以数组形式返回指定列的最早n个值。分区中最早的值具有最低的偏移量。可选的ignorenulls参数控制是否忽略空值。默认值是忽略空值。
如何设置为不忽略空值。我尝试了0/1,对/错

nfs0ujit

nfs0ujit1#

我不确定我使用的是哪个版本的ksqldb。所以我发现confluent平台使用的是版本0.10(https://docs.confluent.io/platform/current/installation/versions-interoperability.html)
因此,此命令无法工作。
但由于这一段,我发现很容易误读文档:

Since: 0.10.0

EARLIEST_BY_OFFSET(col1, [ignoreNulls])
Stream

Return the earliest value for the specified column. The earliest value in the partition

has the lowest offset.

The optional ignoreNulls parameter, available since version 0.13.0, controls whether nulls are ignored. The default

is to ignore null values.

所以他们写“从0.10.0开始”,加上ignorenulls参数,说ignorenulls只能由版本0.13使用。

相关问题