Coverage for docs / docs_src / getting_started / lifespan / confluent / basic.py: 0%

1from pydantic_settings import BaseSettings 

2 

3from faststream import ContextRepo, FastStream 

4from faststream.confluent import KafkaBroker 

5 

6broker = KafkaBroker() 

7app = FastStream(broker) 

8 

9 

10class Settings(BaseSettings): 

11 host: str = "localhost:9092" 

12 

13 

14@app.on_startup 

15async def setup(context: ContextRepo, env: str = ".env"): 

16 settings = Settings(_env_file=env) 

17 context.set_global("settings", settings) 

18 await broker.connect(settings.host)