How to Filter Messages from Stream in ksqlDB

To filter out records in a stream, use the WHERE clause in a SELECT statement.

Here’s an example to get all the products of the furniture category :

SELECT name
FROM products
WHERE category = 'furniture'

Was this article helpful?