diff --git a/serve.py b/serve.py new file mode 100644 index 0000000000..b2e39ddb5f --- /dev/null +++ b/serve.py @@ -0,0 +1,7 @@ +from fastapi import FastAPI + +from faststream.kafka.fastapi import KafkaRouter + +router = KafkaRouter(schema_url=None) +app = FastAPI(lifespan=router.lifespan_context) +app.include_router(router)