Skip to content

Conversation

l4mby
Copy link
Contributor

@l4mby l4mby commented Oct 1, 2025

Add filtering options in stream:

  • Sql Filters
  • Properties Filters
  • Application Properties Filters

Example:

    const consumer = await connection.createConsumer({
      stream: {
        name: streamName,
        offset: Offset.first(),
        matchUnfiltered: false,
        messagePropertiesFilter: { subject: "foo" },
        sqlFilter: "p.subject = 'foo'",
        applicationPropertiesFilter: { test: "foo"},
      },
      messageHandler: (context) => { ... },
    })

@l4mby l4mby linked an issue Oct 1, 2025 that may be closed by this pull request
@l4mby l4mby force-pushed the 70-support-sql-filter-expressions branch from 3a60cca to 86f7d79 Compare October 6, 2025 09:18
@l4mby l4mby merged commit be11c72 into main Oct 6, 2025
4 checks passed
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

Support SQL filter expressions

2 participants