MCPcopy Index your code
hub / github.com/aio-libs/aiokafka

github.com/aio-libs/aiokafka @v0.14.0b1

Chat with this repo
repository ↗ · DeepWiki ↗ · release v0.14.0b1 ↗ · + Follow
1,978 symbols 9,739 edges 112 files 306 documented · 15% 4 cross-repo links
What it actually does AI analysis from the code graph — generated when you open this
loading…

Core symbols most depended-on inside this repo

append
called by 174
aiokafka/producer/message_accumulator.py
done
called by 133
aiokafka/producer/message_accumulator.py
encode
called by 95
aiokafka/protocol/types.py
start
called by 66
aiokafka/producer/producer.py
create_task
called by 61
aiokafka/util.py
start
called by 61
aiokafka/consumer/consumer.py
getone
called by 56
aiokafka/consumer/fetcher.py
assign
called by 55
aiokafka/consumer/consumer.py

Shape

Method 1,229
Class 525
Function 224

Languages

Python99%
C1%

Modules by API surface

aiokafka/protocol/admin.py140 symbols
aiokafka/errors.py110 symbols
tests/test_consumer.py89 symbols
aiokafka/record/_protocols.py76 symbols
aiokafka/consumer/subscription_state.py73 symbols
aiokafka/protocol/types.py64 symbols
aiokafka/conn.py56 symbols
aiokafka/consumer/group_coordinator.py55 symbols
tests/test_coordinator.py54 symbols
aiokafka/producer/sender.py54 symbols
aiokafka/consumer/fetcher.py51 symbols
tests/_testutil.py49 symbols

Used by 4 indexed graphs manifest dependencies, hub-wide

github.com/faust-streaming/faust
github.com/home-assistant/core
github.com/iflytek/astron-agent
github.com/rudderlabs/rudder-server

For agents

$ claude mcp add aiokafka \
  -- python -m otcore.mcp_server <graph>

⬇ download graph artifact