Enable asyncapi documentation for ook

The asyncapi docs are available at /ook/asyncapi and the JSON schema from /ook/asyncapi.json
lsst-sqre · Aug 22, 2024 · f286084 · f286084
1 parent 1930f04
commit f286084
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git 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
@@ -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",
 )