We need to execute KSQL querier to filter our KAFKA streams within NiFi.
How can we achive this . Should we implement custom processor.
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.