You can have a QueryDataTableRecord to watch when changes happen and have that trigger your process.   You may want to try Debezium with Cloudera Kafka   You may want to try Debezium with Cloudera Flink SQL   https://dev.to/tspannhw/simple-change-data-capture-cdc-with-sql-selects-via-apache-nifi-flank-19m4   See:   https://github.com/tspannhw/EverythingApacheNiFi   https://docs.microsoft.com/en-us/sql/database-engine/availability-groups/windows/replicate-track-change-data-capture-always-on-availability?view=sql-server-ver15   https://debezium.io/documentation/reference/connectors/sqlserver.html   https://sandeepkattepogu.medium.com/streaming-data-from-microsoft-sql-server-into-apache-kafka-2fb53282115f   https://www.linkedin.com/pulse/achieving-incremental-fetch-change-data-capture-via-apache-rajpal/   https://www.datainmotion.dev/2021/02/using-apache-nifi-in-openshift-and.html     ... View more