MCPcopy Index your code
hub / github.com/dpkp/kafka-python

github.com/dpkp/kafka-python @3.0.7

repository ↗ · DeepWiki ↗ · release 3.0.7 ↗ · Ask this repo → · + Follow
4,978 symbols 21,492 edges 339 files 1,121 documented · 23% 2 cross-repo links ● updated 6d ago3.0.7 · 2026-06-28★ 5,90015 open issues

Core symbols most depended-on inside this repo

encode
called by 315
kafka/protocol/old/types.py
append
called by 268
kafka/record/abc.py
decode
called by 247
kafka/protocol/old/types.py
get
called by 208
kafka/producer/future.py
emit
called by 192
kafka/protocol/schemas/fields/codegen.py
respond
called by 191
test/mock_broker.py
metric_name
called by 120
kafka/metrics/metrics.py
append
called by 117
kafka/producer/record_accumulator.py

Shape

Method 3,015
Class 1,049
Function 900
Route 14

Languages

Python100%

Modules by API surface

test/consumer/test_coordinator.py180 symbols
kafka/errors.py163 symbols
kafka/producer/transaction_manager.py127 symbols
test/consumer/test_fetcher.py108 symbols
test/net/test_selector.py93 symbols
test/producer/test_sender.py91 symbols
test/producer/test_transaction_manager_mock_broker.py84 symbols
kafka/consumer/fetcher.py82 symbols
kafka/consumer/subscription_state.py80 symbols
test/net/test_manager.py79 symbols
kafka/protocol/old/admin.py77 symbols
kafka/record/default_records.py76 symbols

Used by 2 indexed graphs manifest dependencies, hub-wide

github.com/PostHog/posthog
github.com/apache/doris

Dependencies from manifests, versioned

sphinx8.1.3 · 1×
sphinx-argparse0.5.2 · 1×
sphinx_rtd_theme3.0.2 · 1×

For agents

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

⬇ download graph artifact