Open danphanley opened 6 years ago
What is the schema of the stream you have in mind? We can filter by any column in your schema, so I am not sure what the question is.
The ask here is really about the ability to parse XML from the message body into a column format for filtering.
It sounds like another option could be a UDF like XPATH on an xml column
Deserialize the body of the message (could be XML) into column format, filter on the column value and write the body untouched to a destination topic