Coverage for docs / docs_src / getting_started / subscription / confluent / dynamic.py: 0%

1from faststream.confluent import KafkaBroker, KafkaMessage 

2 

3async def main(): 

4 async with KafkaBroker() as broker: # connect the broker 

5 subscriber = broker.subscriber("test-topic", persistent=False) 

6 await subscriber.start() 

7 

8 message: KafkaMessage | None = await subscriber.get_one(timeout=3.0) 

9 

10 await subscriber.stop() 

11 

12 return message