https://github.com/dpkp/kafka-python
· scanned 2026-06-17 01:58 UTC (1 month, 1 week ago)
154 raw signals (0 security + 154 graph)
Last scanned 1 month, 1 week ago · v2 · last Δ -12.5 (diff) · 125 actionable findings from 1 signal source. 29 repeated signals grouped for readability. Security checks, system graph analysis, and verified AI-agent feedback are merged into one review queue.
All 5119 nodes from the latest scan, grouped by kind. Each node is a unit the engine identified (file, function, endpoint, table…). Most users won't need this view — it's primarily for debugging the engine's graph extraction or for AI agents that want to enumerate the project structure.
| Label | Layer | Status | Path |
|---|---|---|---|
__init__ |
software | healthy | example.py:29 |
stop |
software | healthy | example.py:33 |
run |
software | healthy | example.py:36 |
main |
software | healthy | example.py:51 |
__init__ |
software | healthy | kafka/cluster.py:51 |
metadata_refresh_in_progress |
software | healthy | kafka/cluster.py:86 |
attach |
software | healthy | kafka/cluster.py:90 |
close |
software | healthy | kafka/cluster.py:101 |
start_refresh_loop |
software | healthy | kafka/cluster.py:105 |
_refresh_loop |
software | healthy | kafka/cluster.py:113 |
refresh_metadata |
software | healthy | kafka/cluster.py:139 |
_do_refresh_metadata |
software | healthy | kafka/cluster.py:163 |
_generate_bootstrap_brokers |
software | healthy | kafka/cluster.py:183 |
is_bootstrap |
software | healthy | kafka/cluster.py:196 |
set_topics |
software | healthy | kafka/cluster.py:199 |
add_topic |
software | healthy | kafka/cluster.py:217 |
brokers |
software | healthy | kafka/cluster.py:237 |
bootstrap_brokers |
software | healthy | kafka/cluster.py:245 |
broker_metadata |
software | healthy | kafka/cluster.py:255 |
partitions_for_topic |
software | healthy | kafka/cluster.py:270 |
available_partitions_for_topic |
software | healthy | kafka/cluster.py:284 |
leader_for_partition |
software | healthy | kafka/cluster.py:300 |
is_replica_node |
software | healthy | kafka/cluster.py:308 |
leader_epoch_for_partition |
software | healthy | kafka/cluster.py:337 |
update_partition_leader |
software | healthy | kafka/cluster.py:345 |
partitions_for_broker |
software | healthy | kafka/cluster.py:377 |
get_coordinator |
software | healthy | kafka/cluster.py:389 |
ttl |
software | healthy | kafka/cluster.py:402 |
refresh_backoff |
software | dead | kafka/cluster.py:419 |
request_update |
software | healthy | kafka/cluster.py:423 |
need_update |
software | healthy | kafka/cluster.py:443 |
topics |
software | healthy | kafka/cluster.py:446 |
metadata_request |
software | healthy | kafka/cluster.py:464 |
topic_id |
software | healthy | kafka/cluster.py:479 |
topic_name_for_id |
software | healthy | kafka/cluster.py:487 |
failed_update |
software | healthy | kafka/cluster.py:495 |
update_metadata |
software | healthy | kafka/cluster.py:506 |
add_listener |
software | healthy | kafka/cluster.py:645 |
remove_listener |
software | healthy | kafka/cluster.py:649 |
add_coordinator |
software | healthy | kafka/cluster.py:656 |
__str__ |
software | healthy | kafka/cluster.py:698 |
collect_hosts |
software | healthy | kafka/cluster.py:703 |
expand_to_canonical_bootstrap_hosts |
software | healthy | kafka/cluster.py:725 |
_address_family |
software | healthy | kafka/cluster.py:757 |
get_ip_port_afi |
software | healthy | kafka/cluster.py:778 |
__init__ |
software | healthy | kafka/future.py:14 |
succeeded |
software | healthy | kafka/future.py:22 |
failed |
software | healthy | kafka/future.py:25 |
retriable |
software | healthy | kafka/future.py:28 |
success |
software | healthy | kafka/future.py:31 |
Showing first 50 of this kind. Full payload available via the JSON button at the top of the page.
| Label | Layer | Status | Path |
|---|---|---|---|
Producer |
software | healthy | example.py:9 |
Consumer |
software | healthy | example.py:28 |
ClusterMetadata |
software | healthy | kafka/cluster.py:22 |
Future |
software | healthy | kafka/future.py:10 |
Timer |
software | healthy | kafka/util.py:10 |
WeakMethod |
software | healthy | kafka/util.py:77 |
Dict |
software | healthy | kafka/util.py:113 |
classproperty |
software | healthy | kafka/util.py:129 |
EnumHelper |
software | healthy | kafka/util.py:136 |
KafkaError |
software | healthy | kafka/errors.py:5 |
RetriableError |
software | healthy | kafka/errors.py:20 |
InvalidMetadataError |
software | healthy | kafka/errors.py:24 |
Cancelled |
software | healthy | kafka/errors.py:28 |
CommitFailedError |
software | healthy | kafka/errors.py:32 |
IllegalArgumentError |
software | healthy | kafka/errors.py:40 |
IllegalStateError |
software | healthy | kafka/errors.py:44 |
KafkaConfigurationError |
software | healthy | kafka/errors.py:48 |
KafkaConnectionError |
software | healthy | kafka/errors.py:52 |
KafkaProtocolError |
software | healthy | kafka/errors.py:56 |
CorrelationIdError |
software | healthy | kafka/errors.py:60 |
InvalidReceiveError |
software | healthy | kafka/errors.py:64 |
KafkaTimeoutError |
software | healthy | kafka/errors.py:68 |
MetadataEmptyBrokerList |
software | healthy | kafka/errors.py:72 |
NoOffsetForPartitionError |
software | healthy | kafka/errors.py:76 |
LogTruncationError |
software | healthy | kafka/errors.py:80 |
NodeNotReadyError |
software | healthy | kafka/errors.py:110 |
UnknownBrokerIdError |
software | healthy | kafka/errors.py:114 |
QuotaViolationError |
software | healthy | kafka/errors.py:118 |
StaleMetadata |
software | healthy | kafka/errors.py:122 |
TooManyInFlightRequests |
software | healthy | kafka/errors.py:126 |
UnrecognizedBrokerVersion |
software | healthy | kafka/errors.py:130 |
UnsupportedCodecError |
software | healthy | kafka/errors.py:134 |
TransactionAbortedError |
software | healthy | kafka/errors.py:138 |
BrokerResponseError |
software | healthy | kafka/errors.py:145 |
AuthorizationError |
software | healthy | kafka/errors.py:157 |
NoError |
software | healthy | kafka/errors.py:161 |
UnknownError |
software | healthy | kafka/errors.py:167 |
OffsetOutOfRangeError |
software | healthy | kafka/errors.py:173 |
CorruptRecordError |
software | healthy | kafka/errors.py:180 |
UnknownTopicOrPartitionError |
software | healthy | kafka/errors.py:190 |
InvalidFetchRequestError |
software | healthy | kafka/errors.py:197 |
LeaderNotAvailableError |
software | healthy | kafka/errors.py:203 |
NotLeaderForPartitionError |
software | healthy | kafka/errors.py:211 |
RequestTimedOutError |
software | healthy | kafka/errors.py:220 |
BrokerNotAvailableError |
software | healthy | kafka/errors.py:227 |
ReplicaNotAvailableError |
software | healthy | kafka/errors.py:234 |
MessageSizeTooLargeError |
software | healthy | kafka/errors.py:241 |
StaleControllerEpochError |
software | healthy | kafka/errors.py:250 |
OffsetMetadataTooLargeError |
software | healthy | kafka/errors.py:256 |
NetworkExceptionError |
software | healthy | kafka/errors.py:263 |
Showing first 50 of this kind. Full payload available via the JSON button at the top of the page.
| Label | Layer | Status | Path |
|---|---|---|---|
CHANGES.md |
software | healthy | CHANGES.md |
.readthedocs.yaml |
software | healthy | .readthedocs.yaml |
README.rst |
software | healthy | README.rst |
pyproject.toml |
software | healthy | pyproject.toml |
Makefile |
software | healthy | Makefile |
example.py |
software | healthy | example.py |
LICENSE |
software | healthy | LICENSE |
requirements-dev.txt |
software | healthy | requirements-dev.txt |
AUTHORS.md |
software | healthy | AUTHORS.md |
dependabot.yml |
software | healthy | .github/dependabot.yml |
python-package.yml |
software | healthy | .github/workflows/python-package.yml |
codeql-analysis.yml |
software | healthy | .github/workflows/codeql-analysis.yml |
flakey-test-repro.yml |
software | healthy | .github/workflows/flakey-test-repro.yml |
requirements.txt |
software | healthy | docs/requirements.txt |
Makefile |
software | healthy | docs/Makefile |
conf.py |
software | healthy | docs/conf.py |
custom.css |
software | healthy | docs/_static/custom.css |
structs.py |
software | healthy | kafka/structs.py |
cluster.py |
software | healthy | kafka/cluster.py |
__init__.py |
software | healthy | kafka/__init__.py |
__main__.py |
software | healthy | kafka/__main__.py |
future.py |
software | healthy | kafka/future.py |
util.py |
software | healthy | kafka/util.py |
codec.py |
software | healthy | kafka/codec.py |
version.py |
software | healthy | kafka/version.py |
errors.py |
software | healthy | kafka/errors.py |
wrapper.py |
software | healthy | kafka/serializer/wrapper.py |
__init__.py |
software | healthy | kafka/serializer/__init__.py |
default.py |
software | healthy | kafka/serializer/default.py |
json.py |
software | healthy | kafka/serializer/json.py |
abstract.py |
software | healthy | kafka/serializer/abstract.py |
subscription_state.py |
software | healthy | kafka/consumer/subscription_state.py |
fetcher.py |
software | healthy | kafka/consumer/fetcher.py |
__init__.py |
software | healthy | kafka/consumer/__init__.py |
group.py |
software | healthy | kafka/consumer/group.py |
__main__.py |
software | healthy | kafka/consumer/__main__.py |
varint_speed.py |
software | healthy | kafka/benchmarks/varint_speed.py |
consumer_performance.py |
software | healthy | kafka/benchmarks/consumer_performance.py |
producer_encode_path.py |
software | healthy | kafka/benchmarks/producer_encode_path.py |
__init__.py |
software | healthy | kafka/benchmarks/__init__.py |
README.md |
software | healthy | kafka/benchmarks/README.md |
load_example.py |
software | healthy | kafka/benchmarks/load_example.py |
record_batch_compose.py |
software | healthy | kafka/benchmarks/record_batch_compose.py |
profile_protocol.py |
software | healthy | kafka/benchmarks/profile_protocol.py |
record_batch_read.py |
software | healthy | kafka/benchmarks/record_batch_read.py |
protocol_old_vs_new.py |
software | healthy | kafka/benchmarks/protocol_old_vs_new.py |
producer_performance.py |
software | healthy | kafka/benchmarks/producer_performance.py |
_transactions.py |
software | healthy | kafka/admin/_transactions.py |
_topics.py |
software | healthy | kafka/admin/_topics.py |
_configs.py |
software | healthy | kafka/admin/_configs.py |
Showing first 50 of this kind. Full payload available via the JSON button at the top of the page.
| Label | Layer | Status | Path |
|---|---|---|---|
.github |
software | healthy | .github |
workflows |
software | healthy | .github/workflows |
docs |
software | healthy | docs |
_static |
software | healthy | docs/_static |
kafka |
software | healthy | kafka |
serializer |
software | healthy | kafka/serializer |
consumer |
software | healthy | kafka/consumer |
benchmarks |
software | healthy | kafka/benchmarks |
admin |
software | healthy | kafka/admin |
producer |
software | healthy | kafka/producer |
record |
software | healthy | kafka/record |
net |
software | healthy | kafka/net |
sasl |
software | healthy | kafka/net/sasl |
metrics |
software | healthy | kafka/metrics |
stats |
software | healthy | kafka/metrics/stats |
coordinator |
software | healthy | kafka/coordinator |
assignors |
software | healthy | kafka/coordinator/assignors |
sticky |
software | healthy | kafka/coordinator/assignors/sticky |
cli |
software | healthy | kafka/cli |
consumer |
software | healthy | kafka/cli/consumer |
admin |
software | healthy | kafka/cli/admin |
groups |
software | healthy | kafka/cli/admin/groups |
configs |
software | healthy | kafka/cli/admin/configs |
users |
software | healthy | kafka/cli/admin/users |
transactions |
software | healthy | kafka/cli/admin/transactions |
cluster |
software | healthy | kafka/cli/admin/cluster |
acls |
software | healthy | kafka/cli/admin/acls |
partitions |
software | healthy | kafka/cli/admin/partitions |
topics |
software | healthy | kafka/cli/admin/topics |
producer |
software | healthy | kafka/cli/producer |
protocol |
software | healthy | kafka/protocol |
old |
software | healthy | kafka/protocol/old |
consumer |
software | healthy | kafka/protocol/consumer |
admin |
software | healthy | kafka/protocol/admin |
producer |
software | healthy | kafka/protocol/producer |
schemas |
software | healthy | kafka/protocol/schemas |
fields |
software | healthy | kafka/protocol/schemas/fields |
codecs |
software | healthy | kafka/protocol/schemas/fields/codecs |
resources |
software | healthy | kafka/protocol/schemas/resources |
metadata |
software | healthy | kafka/protocol/metadata |
partitioner |
software | healthy | kafka/partitioner |
test |
software | healthy | test |
consumer |
software | healthy | test/consumer |
admin |
software | healthy | test/admin |
producer |
software | healthy | test/producer |
record |
software | healthy | test/record |
net |
software | healthy | test/net |
sasl |
software | healthy | test/net/sasl |
integration |
software | healthy | test/integration |
protocol |
software | healthy | test/protocol |
Showing first 50 of this kind. Full payload available via the JSON button at the top of the page.
| Label | Layer | Status | Path |
|---|---|---|---|
0.8.2.2 |
network | healthy | .github/workflows/python-package.yml |
0.9.0.1 |
network | healthy | .github/workflows/python-package.yml |
0.10.2.2 |
network | healthy | .github/workflows/python-package.yml |
0.11.0.3 |
network | healthy | .github/workflows/python-package.yml |
0.10.1.0 |
network | healthy | kafka/consumer/fetcher.py |
0.9.0.0 |
network | healthy | kafka/consumer/group.py |
0.11.0.0 |
network | healthy | kafka/record/legacy_records.py |
0.8.1.1 |
network | healthy | test/testutil.py |
127.0.0.1 |
network | healthy | test/test_cluster.py |
10.0.0.1 |
network | healthy | test/test_cluster.py |
10.0.0.2 |
network | healthy | test/test_cluster.py |
10.0.0.5 |
network | healthy | test/test_cluster.py |
1.2.3.4 |
network | healthy | test/net/test_http_connect.py |
| Label | Layer | Status | Path |
|---|---|---|---|
port:9092 |
network | healthy | test/test_mock_broker.py |
port:12 |
network | healthy | test/test_cluster.py |
port:34 |
network | healthy | test/test_cluster.py |
port:57609 |
network | healthy | test/protocol/test_parser.py |
port:1000 |
network | healthy | test/protocol/consumer/test_fetch.py |
port:9000 |
network | healthy | test/protocol/admin/test_protocol_admin.py |
port:9093 |
network | healthy | test/protocol/metadata/test_metadata.py |
| Label | Layer | Status | Path |
|---|---|---|---|
password_literal::test/admin/test_admin_users.py |
security | healthy | test/admin/test_admin_users.py |
password_literal::test/admin/test_admin_users.py |
security | healthy | test/admin/test_admin_users.py |
password_literal::test/admin/test_admin_users.py |
security | healthy | test/admin/test_admin_users.py |
password_literal::test/integration/fixtures.py |
security | healthy | test/integration/fixtures.py |
password_literal::test/integration/fixtures.py |
security | healthy | test/integration/fixtures.py |
password_literal::test/integration/fixtures.py |
security | healthy | test/integration/fixtures.py |
| Label | Layer | Status | Path |
|---|---|---|---|
auth::kafka/admin/client.py |
security | healthy | kafka/admin/client.py |
auth::kafka/net/sasl/oauth.py |
security | healthy | kafka/net/sasl/oauth.py |
auth::kafka/net/sasl/__init__.py |
security | healthy | kafka/net/sasl/__init__.py |
auth::kafka/producer/kafka.py |
security | healthy | kafka/producer/kafka.py |
auth::kafka/consumer/group.py |
security | healthy | kafka/consumer/group.py |
| Label | Layer | Status | Path |
|---|---|---|---|
gha::python-package |
cicd | healthy | .github/workflows/python-package.yml |
gha::codeql-analysis |
cicd | healthy | .github/workflows/codeql-analysis.yml |
gha::flakey-test-repro |
cicd | healthy | .github/workflows/flakey-test-repro.yml |
| Label | Layer | Status | Path |
|---|---|---|---|
build |
cicd | healthy | .github/workflows/python-package.yml |
analyze |
cicd | healthy | .github/workflows/codeql-analysis.yml |
stress |
cicd | healthy | .github/workflows/flakey-test-repro.yml |
| Label | Layer | Status | Path |
|---|---|---|---|
dpkp__kafka-python |
software | healthy | /data/fable5_failed_archive/dpkp__kafka-python |
| Label | Layer | Status | Path |
|---|---|---|---|
kafka |
data | healthy | README.rst |
| Label | Layer | Status | Path |
|---|---|---|---|
vps::aws |
hardware | healthy | kafka/net/sasl/msk.py |
This page is publicly accessible at:
https://repobility.com/scan/3c30319b-3d2f-4ef6-80da-4e6d88ff1177/
To check status programmatically (no auth required):
curl -s https://repobility.com/api/v1/public/scan/3c30319b-3d2f-4ef6-80da-4e6d88ff1177/Important — please don't re-submit the same URL repeatedly. The submission endpoint is idempotent: re-submitting the same git URL returns this same scan_token, not a new one. To re-scan this repo, sign up free and use the dashboard.