Skip to content

Commit

Permalink
Log additional data about Kafka on startup
Browse files Browse the repository at this point in the history
  • Loading branch information
jonathansick committed Aug 13, 2024
1 parent d934b3e commit 9104bf0
Showing 1 changed file with 2 additions and 0 deletions.
2 changes: 2 additions & 0 deletions src/ook/main.py
Original file line number Diff line number Diff line change
Expand Up @@ -40,6 +40,8 @@ async def lifespan(app: FastAPI) -> AsyncIterator:
"Configured Kafka",
bootstrap_servers=config.kafka.bootstrap_servers,
security_protocol=config.kafka.security_protocol.name,
ingest_topic=config.kafka.ingest_topic,
consumer_group=config.kafka.consumer_group_id,
)

await context_dependency.initialize()
Expand Down

0 comments on commit 9104bf0

Please sign in to comment.