Skip to content

support oauthbearer sasl mechanism in kafka binding & support identity guard options with static identity and credentials#1898

Open
ankitk-me wants to merge 3 commits into
aklivity:developfrom
ankitk-me:oauthbearer
Open

support oauthbearer sasl mechanism in kafka binding & support identity guard options with static identity and credentials#1898
ankitk-me wants to merge 3 commits into
aklivity:developfrom
ankitk-me:oauthbearer

Conversation

@ankitk-me

Copy link
Copy Markdown
Contributor

Fixes #1868 #1897

ankitk-me and others added 2 commits June 15, 2026 11:52
- Add `identity` and `credentials` options to the identity guard, with
  corresponding JSON config adapter, module-info wiring, and schema patch
- Propagate incoming stream authorization to SASL credential lookup so
  `oauthbearer` can resolve the JWT via the guard rather than static config
- Detect OAUTHBEARER authentication failure signalled via non-empty `authBytes`
  with `errorCode=0`, as used by Kafka 4.x
- Add `http.kafka.oneway.oauthbearer` example demonstrating SASL/OAUTHBEARER
  with a pre-signed RS256 JWT validated against a JWKS endpoint

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
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 identity guard options with static identity and credentials feat(binding-kafka): support SASL/OAUTHBEARER mechanism for Kafka client

1 participant