From f286084c2213c141548ae7af7f6e7e6265c02a49 Mon Sep 17 00:00:00 2001 From: Jonathan Sick Date: Thu, 22 Aug 2024 14:33:43 -0400 Subject: [PATCH] Enable asyncapi documentation for ook The asyncapi docs are available at /ook/asyncapi and the JSON schema from /ook/asyncapi.json --- src/ook/factory.py | 2 +- src/ook/kafkarouter.py | 4 +++- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/src/ook/factory.py b/src/ook/factory.py index 38e78c6..cb0817e 100644 --- a/src/ook/factory.py +++ b/src/ook/factory.py @@ -64,7 +64,7 @@ async def create( http_client=http_client, kafka_broker=broker, kafka_ingest_publisher=broker.publisher( - config.ingest_kafka_topic, title="Ook ingest requests" + config.ingest_kafka_topic, description="Ook ingest requests" ), algolia_client=algolia_client, ) diff --git a/src/ook/kafkarouter.py b/src/ook/kafkarouter.py index d9f71db..b0057a2 100644 --- a/src/ook/kafkarouter.py +++ b/src/ook/kafkarouter.py @@ -15,5 +15,7 @@ kafka_security = BaseSecurity(ssl_context=config.kafka.ssl_context) kafka_router = KafkaRouter( - config.kafka.bootstrap_servers, security=kafka_security + config.kafka.bootstrap_servers, + security=kafka_security, + schema_url=f"{config.path_prefix}/asyncapi", )