Precisely control your data flow with powerful filtering options. Learn to filter by operation type, column values, and even nested JSON fields for efficient CDC processing.
insert
update
delete
read
messages for each row in the table, regardless of which operations you specify.true
or false
). Filter functions that return non-boolean values will fail to execute.
action
: The operation type (e.g., “insert”, “update”, “delete”)record
: The full row/record data as a map with string keyschanges
: For update operations, contains the old values that were changedmetadata
: Additional information like table name, timestamp, etc.true
.
If any of these conditions fail, the message will not be delivered to the sink.