We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
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}
The text was updated successfully, but these errors were encountered:
@akrambek Perhaps we need to indicate this intent via the AsyncAPI spec, then honor it during config generation?
Sorry, something went wrong.
For example, in AsyncAPI operation bindings.
bindings: x-zilla-sse-kafka: filters: headers: zilla:identity: {identity}
generates
- when: - path: /payment-requests exit: kafka_cache_client0 with: event: id: '["${base64(key)}","${etag}"]' topic: payment-requests filters: - headers: zilla:identity: ${guarded[<guard-name>].identity}
sse-kafka
Successfully merging a pull request may close this issue.
Add support for sse-kafka filtering.
For example.
The text was updated successfully, but these errors were encountered: