Coverage for docs / docs_src / kafka / security / sasl_oauthbearer.py: 0%

1import ssl 

2 

3from faststream.kafka import KafkaBroker 

4from faststream.security import SASLOAuthBearer 

5 

6ssl_context = ssl.create_default_context() 

7security = SASLOAuthBearer( 

8 use_ssl=True, 

9 ssl_context=ssl_context, 

10) 

11 

12broker = KafkaBroker( 

13 "localhost:9092", 

14 security=security, 

15 sasl_oauth_token_provider=..., 

16)