Coverage for docs / docs_src / getting_started / routers / kafka / delay_equal.py: 69%

1from faststream import FastStream (empty)

2from faststream.kafka import KafkaBroker, KafkaRouter (empty)

3 

4broker = KafkaBroker("localhost:9092") (empty)

5app = FastStream(broker) (empty)

6 

7router = KafkaRouter() (empty)

8 

9@router.subscriber("test-topic") (empty)

10@router.publisher("outer-topic") (empty)

11async def handle(name: str, user_id: int): (empty)

12 assert name == "John" 

13 assert user_id == 1 

14 return "Hi!" 

15 

16broker.include_router(router) (empty)

17 

18@app.after_startup (empty)

19async def test(): (empty)

20 await broker.publish({"name": "John", "user_id": 1}, topic="test-topic")