Skip to content

AsyncAPI sse kafka filtering support #1137

@akrambek

Description

@akrambek

Add support for sse-kafka filtering.

For example.

      - when:
          - path: /payment-requests
        exit: kafka_cache_client1808eec1-480a-4f24-af7d-3a99101cc5b3
        with:
          event:
            id: '["${base64(key)}","${etag}"]'
          topic: payment-requests
          filters:
            - headers:
                zilla:identity: ${guarded['jwt3dc23de6-5185-46f8-86f7-717c3b023d8a'].identity}

Metadata

Metadata

Assignees

No one assigned

    Labels

    bugSomething isn't working

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions