KAFKA KSQL within NIFI flow

[#1]

Hi,

We need to execute KSQL querier to filter our KAFKA streams within NiFi.

How can we achive this . Should we implement custom processor.

Regards,

[#2]

Hi @yazeed salem

NiFi has a processor called QueryRecord that can be used to do SQL on data coming from Kafka : https://nifi.apache.org/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.7.1/org.apache...

This is not KSQL.

Thanks

Abdelkrim