Search code examples
apache-kafkaksqldb

Ksql Can't find any functions with the name 'COUNT_DISTINCT'

I am running ksql cli using

docker run --net=host --interactive --tty confluentinc/cp-ksql-cli:latest http://localhost:8088

I have created a stream

CREATE STREAM RAW (`nodeId` INT,`data` STRING) WITH (kafka_topic='raw-data', value_format='JSON',partitions=3);

When I run query for count_distinct

SELECT COUNT_DISTINCT(`nodeId`) FROM RAW EMIT CHANGES;

It says

Can't find any functions with the name 'COUNT_DISTINCT'

The documentation specifies this function

https://docs.ksqldb.io/en/latest/developer-guide/ksqldb-reference/aggregate-functions/

Solution

  • As guided by @OneCricketeer solved by using latest docker images as described in https://ksqldb.io/quickstart.html