Coverage for docs / docs_src / confluent / security / custom_config.py: 0%

1from faststream.confluent import KafkaBroker 

2from faststream.security import SASLPlaintext 

3 

4security = SASLPlaintext( 

5 username="admin", 

6 password="password", 

7) 

8 

9config = {"ssl.ca.location": "~/my_certs/CRT_cacerts.pem"} 

10 

11broker = KafkaBroker("localhost:9092", security=security, config=config)