MCPcopy
hub / github.com/ag2ai/faststream / confluent.py

File confluent.py

tests/mypy/confluent.py:None–None  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

1import asyncio
2
3from confluent_kafka import Message
4from typing_extensions import assert_type

Callers

nothing calls this directly

Calls 4

KafkaBrokerClass · 0.90
KafkaRouterClass · 0.90
include_routersMethod · 0.80
include_routerMethod · 0.45

Tested by

no test coverage detected