Get Started Free

Event Filter

Event Processing Applications may need to operate over a subset of Events in an Event Stream.


How can an application select only the relevant events (or discard uninteresting events) from an Event Stream?




As an example, the streaming database ksqlDB lets us create a filtered Event Stream using familiar SQL syntax:

CREATE STREAM payments_only WITH (kafka_topic = 'transactions-topic') AS
    SELECT *
      FROM all_transactions
      WHERE type = 'purchase';

The Kafka Streams client library of Apache Kafka® provides a filter operator in its DSL. This operator filters out events that do not match a given predicate:

  .filter((key, transaction) -> transaction.type == "purchase")


Confluent Cloud is a fully managed Apache Kafka service available on all three major clouds. Try it for free today.

Try it for free