Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

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

Jump to bottom

Adds SASLOAuthBearer flow to AIO Kafka's Faststream Security Parsing #1761

Merged
merged 9 commits into from
Sep 5, 2024
Merged

Adds SASLOAuthBearer flow to AIO Kafka's Faststream Security Parsing #1761

Changes from 1 commit
Commits
Show all changes
9 commits
Select commit Hold shift + click to select a range
60ceaa9
Added same OAUTHBEARER security parsing as Confluent Kafka to AIO Kafka
sinnwise Sep 5, 2024
86db950
Added same OAUTHBEARER security parsing as Confluent Kafka to AIO Kafka
sinnwise Sep 5, 2024
cd10720
Added SSL Context to Kafka AIO Oauth flow
sinnwise Sep 5, 2024
803e362
Added more docs for Kafka OAuth Security Flow.
sinnwise Sep 5, 2024
d24e6f3
linting
sinnwise Sep 5, 2024
8d55a33
Merge branch 'main' into feat/oauth-security-kafka-aio
Lancetnik Sep 5, 2024
09ef14d
linting
sinnwise Sep 5, 2024
76399c8
Merge remote-tracking branch 'origin/feat/oauth-security-kafka-aio' i…
sinnwise Sep 5, 2024
70d1ba5
Merge branch 'main' into feat/oauth-security-kafka-aio
sifex Sep 5, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
linting
  • Loading branch information
@sinnwise
sinnwise committed Sep 5, 2024
commit 09ef14d1d10b38f488266577b21aa514f369a2e7
2 changes: 1 addition & 1 deletion docs/docs/en/kafka/security.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -54,7 +54,7 @@ This chapter discusses the security options available in **FastStream** and how

### 4. SASLOAuthBearer Object with SSL/TLS

**Purpose:** The `SASLOAuthBearer` is used for authentication using the `OAUTHBEARER` sasl_mechanism. You'll likely need to provide your own `sasl_oauth_token_provider` to the KafkaBroker object in order to complete the authentication flow, such as AWS's [`aws-msk-iam-sasl-signer-python`](https://github.com/aws/aws-msk-iam-sasl-signer-python). For more information see AIOKafka's documentation on [AbstractTokenProvider](https://aiokafka.readthedocs.io/en/stable/api.html#aiokafka.abc.AbstractTokenProvider).
**Purpose:** The `SASLOAuthBearer` is used for authentication using the `OAUTHBEARER` sasl_mechanism. You'll likely need to provide your own `sasl_oauth_token_provider` to the KafkaBroker object in order to complete the authentication flow, such as AWS's [`aws-msk-iam-sasl-signer-python`](https://github.com/aws/aws-msk-iam-sasl-signer-python). For more information see AIOKafka's documentation on [AbstractTokenProvider](https://aiokafka.readthedocs.io/en/stable/api.html#aiokafka.abc.AbstractTokenProvider).

**Usage:**

Expand Down