Public scan — anyone with this URL can view this analysis. Sign up to track your own repos privately, run scheduled re-scans, and get AI fix prompts via your dashboard.
Sign up free Scan another repo

dpkp/kafka-python

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)

File as issue Image
UNIFIED Repobility · multi-layer engine · AI coders

Complete repo analysis

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.

JSON
Combined
64.2
/100
Security checks
64
0 findings
System graph
64
77.8% cov · 125 findings
Critical
1
click to filter
Agents
10
0 votes
Crowd
0
reported
Severity distribution — click a segment to filter
Active filters: excluding tests × Reset all
Severity: Critical 1 High 2 Medium 6 Low 86 9-Layer: Software Security Quality Integrity Frontend Hardware Data Network Cicd Source: Security checks 0 System graph 125 Crowd 0 Layer: Software 25 Network 3 Security 3 Cicd 2 Quality 92
Corpus Intelligence Cross-corpus context (cohort percentile, top patterns, fix plan) is shown only on repositories you own. Sign up and connect your repo to view it.
Scan summary Repository scanned at 64.2/100 with 77.8% coverage. It contains 5119 nodes across 0 cross-layer flows, written primarily in mixed languages. Engine surfaced 154 findings — concentrated in quality (109), software (25), cicd (14). Risk profile is high: 1 critical, 2 high, 8 medium. Recommended next step: open the quality layer findings first — that's where the highest-impact wins live.

Showing 91 of 125 actionable findings. 154 raw detector signals were grouped into reader-sized issues. Click TP / FP to vote on a finding's accuracy — votes adjust the confidence weighting and improve detection across the platform.

high System graph security security conf 1.00 Insecure pattern 'exec_used' in docs/conf.py:65
Found a known-risky pattern (exec_used). Review and replace if possible.
docs/conf.py:65 Exec used
high System graph security security conf 1.00 Insecure pattern 'exec_used' in kafka/protocol/schemas/fields/struct.py:189
Found a known-risky pattern (exec_used). Review and replace if possible.
kafka/protocol/schemas/fields/struct.py:189 Exec used
medium System graph cicd CI/CD security conf 1.00 3 occurrences GitHub Action is tag-pinned rather than SHA-pinned
github/codeql-action/init@v4 can move without a code change in this repo. Pin third-party actions to a reviewed 40-character commit SHA.
lines 43, 54, 67
.github/workflows/codeql-analysis.yml:43, 54, 67 (3 hits)
CI/CD securitySupply chainGithub actions
medium System graph quality Integrity conf 1.00 Network/subprocess call without timeout or try/except — test/integration/fixtures.py:456
`subprocess.Popen(...)` here lacks both a `timeout=` arg and an enclosing try/except. This is exactly the class of bug that took down our git-clone earlier (HTTP/2 stream cancel surfaced as a fatal). Add a `timeout=` and wrap in try/except, or use a wrapper that retries.
runtime safetyRobustness
medium System graph quality Integrity conf 1.00 Network/subprocess call without timeout or try/except — test/service.py:61
`subprocess.Popen(...)` here lacks both a `timeout=` arg and an enclosing try/except. This is exactly the class of bug that took down our git-clone earlier (HTTP/2 stream cancel surfaced as a fatal). Add a `timeout=` and wrap in try/except, or use a wrapper that retries.
runtime safetyRobustness
low System graph quality Debug conf 1.00 Debug logging residue appears in source files
Found 86 console/debugger/print-style debug statements in non-test source. This is a common fast-generation residue before production cleanup.
CleanupRepo hardeningGenerated repo pattern
low System graph cicd CI/CD security conf 1.00 11 occurrences GitHub Action is tag-pinned rather than SHA-pinned
actions/checkout@v6 can move without a code change in this repo. Pin third-party actions to a reviewed 40-character commit SHA.
3 files, 11 locations
.github/workflows/flakey-test-repro.yml:65, 80, 87, 96, 134 (5 hits)
.github/workflows/python-package.yml:60, 74, 80, 88, 105 (5 hits)
.github/workflows/codeql-analysis.yml:39
CI/CD securitySupply chainGithub actions
low System graph quality Integrity conf 1.00 18 occurrences Near-duplicate function bodies in 2 places
Functions with the same first-5-line body hash: example.py:stop, example.py:stop This is *the* AI-coder failure mode (4× more duplication in vibe-coded repos — see https://jw.hn/ai-code-hygiene). Consolidate or document why they're separate.
18 occurrences
repo-level (18 hits)
duplicatesduplication
low System graph quality Integrity conf 1.00 Near-duplicate function bodies in 3 places
Functions with the same first-5-line body hash: kafka/consumer/subscription_state.py:paused_partitions, kafka/consumer/subscription_state.py:pause, kafka/consumer/subscription_state.py:pause This is *the* AI-coder failure mode (4× more duplication in vibe-coded repos — see https://jw.hn/ai-code-hy…
duplicatesduplication
low System graph quality Integrity conf 1.00 Near-duplicate function bodies in 4 places
Functions with the same first-5-line body hash: kafka/serializer/abstract.py:serialize, kafka/serializer/abstract.py:deserialize, kafka/metrics/dict_reporter.py:configure, test/service.py:open This is *the* AI-coder failure mode (4× more duplication in vibe-coded repos — see https://jw.hn/ai-code-…
duplicatesduplication
low System graph quality Integrity conf 1.00 Old/deprecated-named symbol `_message_generator_v2` in kafka/consumer/group.py:1307
Names with suffixes like `_old`, `_v1`, `_deprecated` usually indicate replaced-but-not-removed code (typical AI-coder leftover). Confirm and delete, or rename if it's the active version.
old markerDead code
low System graph quality Integrity conf 1.00 Old/deprecated-named symbol `_zero_copy` in kafka/protocol/schemas/fields/base.py:72
Names with suffixes like `_old`, `_v1`, `_deprecated` usually indicate replaced-but-not-removed code (typical AI-coder leftover). Confirm and delete, or rename if it's the active version.
old markerDead code
low System graph quality Integrity conf 1.00 Old/deprecated-named symbol `AddOffsetsToTxnResponse_v1` in kafka/protocol/old/add_offsets_to_txn.py:14
Names with suffixes like `_old`, `_v1`, `_deprecated` usually indicate replaced-but-not-removed code (typical AI-coder leftover). Confirm and delete, or rename if it's the active version.
old markerDead code
low System graph quality Integrity conf 1.00 Old/deprecated-named symbol `AddPartitionsToTxnResponse_v1` in kafka/protocol/old/add_partitions_to_txn.py:20
Names with suffixes like `_old`, `_v1`, `_deprecated` usually indicate replaced-but-not-removed code (typical AI-coder leftover). Confirm and delete, or rename if it's the active version.
old markerDead code
low System graph quality Integrity conf 1.00 Old/deprecated-named symbol `ApiVersionsResponse_v1` in kafka/protocol/old/api_versions.py:49
Names with suffixes like `_old`, `_v1`, `_deprecated` usually indicate replaced-but-not-removed code (typical AI-coder leftover). Confirm and delete, or rename if it's the active version.
old markerDead code
low System graph quality Integrity conf 1.00 Old/deprecated-named symbol `batch_append_v1` in kafka/benchmarks/record_batch_compose.py:76
Names with suffixes like `_old`, `_v1`, `_deprecated` usually indicate replaced-but-not-removed code (typical AI-coder leftover). Confirm and delete, or rename if it's the active version.
old markerDead code
low System graph quality Integrity conf 1.00 Old/deprecated-named symbol `batch_read_v1` in kafka/benchmarks/record_batch_read.py:81
Names with suffixes like `_old`, `_v1`, `_deprecated` usually indicate replaced-but-not-removed code (typical AI-coder leftover). Confirm and delete, or rename if it's the active version.
old markerDead code
low System graph quality Integrity conf 1.00 Old/deprecated-named symbol `CreateTopicsResponse_v1` in kafka/protocol/old/admin.py:20
Names with suffixes like `_old`, `_v1`, `_deprecated` usually indicate replaced-but-not-removed code (typical AI-coder leftover). Confirm and delete, or rename if it's the active version.
old markerDead code
low System graph quality Integrity conf 1.00 Old/deprecated-named symbol `encode_ApiVersionsReq_v0_old` in kafka/benchmarks/protocol_old_vs_new.py:308
Names with suffixes like `_old`, `_v1`, `_deprecated` usually indicate replaced-but-not-removed code (typical AI-coder leftover). Confirm and delete, or rename if it's the active version.
old markerDead code
low System graph quality Integrity conf 1.00 Old/deprecated-named symbol `EndTxnResponse_v1` in kafka/protocol/old/end_txn.py:14
Names with suffixes like `_old`, `_v1`, `_deprecated` usually indicate replaced-but-not-removed code (typical AI-coder leftover). Confirm and delete, or rename if it's the active version.
old markerDead code
low System graph quality Integrity conf 1.00 Old/deprecated-named symbol `FetchResponse_v1` in kafka/protocol/old/fetch.py:28
Names with suffixes like `_old`, `_v1`, `_deprecated` usually indicate replaced-but-not-removed code (typical AI-coder leftover). Confirm and delete, or rename if it's the active version.
old markerDead code
low System graph quality Integrity conf 1.00 Old/deprecated-named symbol `FindCoordinatorResponse_v1` in kafka/protocol/old/find_coordinator.py:19
Names with suffixes like `_old`, `_v1`, `_deprecated` usually indicate replaced-but-not-removed code (typical AI-coder leftover). Confirm and delete, or rename if it's the active version.
old markerDead code
low System graph quality Integrity conf 1.00 Old/deprecated-named symbol `InitProducerIdResponse_v1` in kafka/protocol/old/init_producer_id.py:16
Names with suffixes like `_old`, `_v1`, `_deprecated` usually indicate replaced-but-not-removed code (typical AI-coder leftover). Confirm and delete, or rename if it's the active version.
old markerDead code
low System graph quality Integrity conf 1.00 Old/deprecated-named symbol `JoinGroupResponse_v1` in kafka/protocol/old/group.py:34
Names with suffixes like `_old`, `_v1`, `_deprecated` usually indicate replaced-but-not-removed code (typical AI-coder leftover). Confirm and delete, or rename if it's the active version.
old markerDead code
low System graph quality Integrity conf 1.00 Old/deprecated-named symbol `ListOffsetsResponse_v1` in kafka/protocol/old/list_offsets.py:25
Names with suffixes like `_old`, `_v1`, `_deprecated` usually indicate replaced-but-not-removed code (typical AI-coder leftover). Confirm and delete, or rename if it's the active version.
old markerDead code
low System graph quality Integrity conf 1.00 Old/deprecated-named symbol `MetadataResponse_v1` in kafka/protocol/old/metadata.py:25
Names with suffixes like `_old`, `_v1`, `_deprecated` usually indicate replaced-but-not-removed code (typical AI-coder leftover). Confirm and delete, or rename if it's the active version.
old markerDead code
low System graph quality Integrity conf 1.00 Old/deprecated-named symbol `OffsetCommitResponse_v1` in kafka/protocol/old/commit.py:17
Names with suffixes like `_old`, `_v1`, `_deprecated` usually indicate replaced-but-not-removed code (typical AI-coder leftover). Confirm and delete, or rename if it's the active version.
old markerDead code
low System graph quality Integrity conf 1.00 Old/deprecated-named symbol `OffsetForLeaderEpochResponse_v1` in kafka/protocol/old/offset_for_leader_epoch.py:17
Names with suffixes like `_old`, `_v1`, `_deprecated` usually indicate replaced-but-not-removed code (typical AI-coder leftover). Confirm and delete, or rename if it's the active version.
old markerDead code
low System graph quality Integrity conf 1.00 Old/deprecated-named symbol `ProduceResponse_v1` in kafka/protocol/old/produce.py:21
Names with suffixes like `_old`, `_v1`, `_deprecated` usually indicate replaced-but-not-removed code (typical AI-coder leftover). Confirm and delete, or rename if it's the active version.
old markerDead code
low System graph quality Integrity conf 1.00 Old/deprecated-named symbol `record_batch_data_v2` in test/record/test_records.py:9
Names with suffixes like `_old`, `_v1`, `_deprecated` usually indicate replaced-but-not-removed code (typical AI-coder leftover). Confirm and delete, or rename if it's the active version.
old markerDead code
low System graph quality Integrity conf 1.00 Old/deprecated-named symbol `SaslAuthenticateResponse_v1` in kafka/protocol/old/sasl_authenticate.py:14
Names with suffixes like `_old`, `_v1`, `_deprecated` usually indicate replaced-but-not-removed code (typical AI-coder leftover). Confirm and delete, or rename if it's the active version.
old markerDead code
low System graph quality Integrity conf 1.00 Old/deprecated-named symbol `SaslHandshakeResponse_v1` in kafka/protocol/old/sasl_handshake.py:17
Names with suffixes like `_old`, `_v1`, `_deprecated` usually indicate replaced-but-not-removed code (typical AI-coder leftover). Confirm and delete, or rename if it's the active version.
old markerDead code
low System graph quality Integrity conf 1.00 Old/deprecated-named symbol `test__handle_list_offsets_response_v1` in test/consumer/test_fetcher.py:437
Names with suffixes like `_old`, `_v1`, `_deprecated` usually indicate replaced-but-not-removed code (typical AI-coder leftover). Confirm and delete, or rename if it's the active version.
old markerDead code
low System graph quality Integrity conf 1.00 Old/deprecated-named symbol `test_duration_filter_requires_v1` in test/admin/test_admin_transactions.py:171
Names with suffixes like `_old`, `_v1`, `_deprecated` usually indicate replaced-but-not-removed code (typical AI-coder leftover). Confirm and delete, or rename if it's the active version.
old markerDead code
low System graph quality Integrity conf 1.00 Old/deprecated-named symbol `test_kafka_consumer_offsets_for_time_old` in test/integration/test_consumer_integration.py:303
Names with suffixes like `_old`, `_v1`, `_deprecated` usually indicate replaced-but-not-removed code (typical AI-coder leftover). Confirm and delete, or rename if it's the active version.
old markerDead code
low System graph quality Integrity conf 1.00 Old/deprecated-named symbol `test_lz4_old` in test/test_codec.py:98
Names with suffixes like `_old`, `_v1`, `_deprecated` usually indicate replaced-but-not-removed code (typical AI-coder leftover). Confirm and delete, or rename if it's the active version.
old markerDead code
low System graph quality Integrity conf 1.00 Old/deprecated-named symbol `test_proxy_url_takes_precedence_over_legacy` in test/net/test_manager.py:75
Names with suffixes like `_old`, `_v1`, `_deprecated` usually indicate replaced-but-not-removed code (typical AI-coder leftover). Confirm and delete, or rename if it's the active version.
old markerDead code
low System graph quality Integrity conf 1.00 Old/deprecated-named symbol `test_read_write_serde_v2` in test/record/test_default_records.py:22
Names with suffixes like `_old`, `_v1`, `_deprecated` usually indicate replaced-but-not-removed code (typical AI-coder leftover). Confirm and delete, or rename if it's the active version.
old markerDead code
low System graph quality Integrity conf 1.00 Old/deprecated-named symbol `test_subscription_copy` in test/consumer/test_consumer.py:23
Names with suffixes like `_old`, `_v1`, `_deprecated` usually indicate replaced-but-not-removed code (typical AI-coder leftover). Confirm and delete, or rename if it's the active version.
old markerDead code
low System graph quality Integrity conf 1.00 Old/deprecated-named symbol `TxnOffsetCommitResponse_v1` in kafka/protocol/old/txn_offset_commit.py:17
Names with suffixes like `_old`, `_v1`, `_deprecated` usually indicate replaced-but-not-removed code (typical AI-coder leftover). Confirm and delete, or rename if it's the active version.
old markerDead code
low System graph software Dead code conf 1.00 Possibly dead Python function: bench_build_and_close
No callers detected by AST scan in this repo. Could be exported for external callers or a framework handler.
kafka/benchmarks/producer_encode_path.py:58
low System graph software Dead code conf 1.00 Possibly dead Python function: bench_encode
No callers detected by AST scan in this repo. Could be exported for external callers or a framework handler.
kafka/benchmarks/producer_encode_path.py:79
low System graph software Dead code conf 1.00 Possibly dead Python function: bench_full_pipeline
No callers detected by AST scan in this repo. Could be exported for external callers or a framework handler.
kafka/benchmarks/producer_encode_path.py:101
low System graph software Dead code conf 1.00 Possibly dead Python function: commit_async
No callers detected by AST scan in this repo. Could be exported for external callers or a framework handler.
kafka/consumer/group.py:592
low System graph software Dead code conf 1.00 Possibly dead Python function: decode_varint_1
No callers detected by AST scan in this repo. Could be exported for external callers or a framework handler.
kafka/benchmarks/varint_speed.py:282
low System graph software Dead code conf 1.00 Possibly dead Python function: decode_varint_2
No callers detected by AST scan in this repo. Could be exported for external callers or a framework handler.
kafka/benchmarks/varint_speed.py:315
low System graph software Dead code conf 1.00 Possibly dead Python function: decode_varint_3
No callers detected by AST scan in this repo. Could be exported for external callers or a framework handler.
kafka/benchmarks/varint_speed.py:330
low System graph software Dead code conf 1.00 Possibly dead Python function: encode_varint_1
No callers detected by AST scan in this repo. Could be exported for external callers or a framework handler.
kafka/benchmarks/varint_speed.py:85
low System graph software Dead code conf 1.00 Possibly dead Python function: encode_varint_2
No callers detected by AST scan in this repo. Could be exported for external callers or a framework handler.
kafka/benchmarks/varint_speed.py:118
low System graph software Dead code conf 1.00 Possibly dead Python function: encode_varint_4
No callers detected by AST scan in this repo. Could be exported for external callers or a framework handler.
kafka/benchmarks/varint_speed.py:145
low System graph software Dead code conf 1.00 Possibly dead Python function: has_partitions_to_add
No callers detected by AST scan in this repo. Could be exported for external callers or a framework handler.
kafka/producer/transaction_manager.py:291
low System graph software Dead code conf 1.00 Possibly dead Python function: has_producer_id_and_epoch
No callers detected by AST scan in this repo. Could be exported for external callers or a framework handler.
kafka/producer/transaction_manager.py:447
low System graph software Dead code conf 1.00 Possibly dead Python function: highwater
No callers detected by AST scan in this repo. Could be exported for external callers or a framework handler.
kafka/consumer/group.py:904
low System graph software Dead code conf 1.00 Possibly dead Python function: in_flight_fetches
No callers detected by AST scan in this repo. Could be exported for external callers or a framework handler.
kafka/consumer/fetcher.py:261
low System graph software Dead code conf 1.00 Possibly dead Python function: lz4f_decode
No callers detected by AST scan in this repo. Could be exported for external callers or a framework handler.
kafka/codec.py:235
low System graph software Dead code conf 1.00 Possibly dead Python function: partitions_for
No callers detected by AST scan in this repo. Could be exported for external callers or a framework handler.
kafka/producer/kafka.py:729
low System graph software Dead code conf 1.00 Possibly dead Python function: refresh_backoff
No callers detected by AST scan in this repo. Could be exported for external callers or a framework handler.
kafka/cluster.py:419
low System graph software Dead code conf 1.00 Possibly dead Python function: response_errors
No callers detected by AST scan in this repo. Could be exported for external callers or a framework handler.
kafka/admin/_topics.py:251
low System graph software Dead code conf 1.00 Possibly dead Python function: response_errors
No callers detected by AST scan in this repo. Could be exported for external callers or a framework handler.
kafka/admin/_partitions.py:256
low System graph software Dead code conf 1.00 Possibly dead Python function: seek_to_beginning
No callers detected by AST scan in this repo. Could be exported for external callers or a framework handler.
kafka/consumer/group.py:1005
low System graph software Dead code conf 1.00 Possibly dead Python function: size_of_varint_1
No callers detected by AST scan in this repo. Could be exported for external callers or a framework handler.
kafka/benchmarks/varint_speed.py:235
low System graph software Dead code conf 1.00 Possibly dead Python function: size_of_varint_2
No callers detected by AST scan in this repo. Could be exported for external callers or a framework handler.
kafka/benchmarks/varint_speed.py:248
low System graph software Dead code conf 1.00 Possibly dead Python function: top_level_error
No callers detected by AST scan in this repo. Could be exported for external callers or a framework handler.
kafka/admin/_partitions.py:355
low System graph software Dead code conf 1.00 Possibly dead Python function: wrapper
No callers detected by AST scan in this repo. Could be exported for external callers or a framework handler.
kafka/util.py:122
low System graph software Dead code conf 1.00 Possibly dead Python function: wrapper
No callers detected by AST scan in this repo. Could be exported for external callers or a framework handler.
kafka/producer/kafka.py:647
low System graph quality Integrity conf 1.00 Stub function `add_arguments` (body is just `pass`/`return`) — kafka/cli/admin/cluster/describe.py:6
Likely an AI scaffold that was never filled in. Remove or implement.
Empty handlerDead code
low System graph quality Integrity conf 1.00 Stub function `add_arguments` (body is just `pass`/`return`) — kafka/cli/admin/cluster/describe_quorum.py:6
Likely an AI scaffold that was never filled in. Remove or implement.
Empty handlerDead code
low System graph quality Integrity conf 1.00 Stub function `add_arguments` (body is just `pass`/`return`) — kafka/cli/admin/topics/list.py:6
Likely an AI scaffold that was never filled in. Remove or implement.
Empty handlerDead code
low System graph quality Integrity conf 1.00 Stub function `auth_bytes` (body is just `pass`/`return`) — kafka/net/sasl/abc.py:10
Likely an AI scaffold that was never filled in. Remove or implement.
Empty handlerDead code
low System graph quality Integrity conf 1.00 Stub function `checksum` (body is just `pass`/`return`) — kafka/record/default_records.py:428
Likely an AI scaffold that was never filled in. Remove or implement.
Empty handlerDead code
low System graph quality Integrity conf 1.00 Stub function `configure` (body is just `pass`/`return`) — kafka/metrics/dict_reporter.py:77
Likely an AI scaffold that was never filled in. Remove or implement.
Empty handlerDead code
low System graph quality Integrity conf 1.00 Stub function `handle_response` (body is just `pass`/`return`) — kafka/producer/transaction_manager.py:894
Likely an AI scaffold that was never filled in. Remove or implement.
Empty handlerDead code
low System graph quality Integrity conf 1.00 Stub function `handshake` (body is just `pass`/`return`) — kafka/net/transport.py:335
Likely an AI scaffold that was never filled in. Remove or implement.
Empty handlerDead code
low System graph quality Integrity conf 1.00 Stub function `is_request` (body is just `pass`/`return`) — kafka/protocol/old/api.py:84
Likely an AI scaffold that was never filled in. Remove or implement.
Empty handlerDead code
low System graph quality Integrity conf 1.00 Stub function `on_assignment` (body is just `pass`/`return`) — kafka/coordinator/assignors/range.py:80
Likely an AI scaffold that was never filled in. Remove or implement.
Empty handlerDead code
low System graph quality Integrity conf 1.00 Stub function `on_assignment` (body is just `pass`/`return`) — kafka/coordinator/assignors/roundrobin.py:100
Likely an AI scaffold that was never filled in. Remove or implement.
Empty handlerDead code
low System graph quality Integrity conf 1.00 Stub function `open` (body is just `pass`/`return`) — test/service.py:24
Likely an AI scaffold that was never filled in. Remove or implement.
Empty handlerDead code
low System graph quality Integrity conf 1.00 Stub function `partition` (body is just `pass`/`return`) — kafka/partitioner/abc.py:6
Likely an AI scaffold that was never filled in. Remove or implement.
Empty handlerDead code
low System graph quality Integrity conf 1.00 Stub function `resume_reading` (body is just `pass`/`return`) — test/mock_broker.py:108
Likely an AI scaffold that was never filled in. Remove or implement.
Empty handlerDead code
low System graph quality Integrity conf 1.00 Stub function `serialize` (body is just `pass`/`return`) — kafka/serializer/abstract.py:7
Likely an AI scaffold that was never filled in. Remove or implement.
Empty handlerDead code
low System graph quality Integrity conf 1.00 Stub function `update` (body is just `pass`/`return`) — kafka/metrics/stats/sampled_stat.py:29
Likely an AI scaffold that was never filled in. Remove or implement.
Empty handlerDead code
low System graph quality Complexity conf 1.00 Very large file: kafka/consumer/fetcher.py (2012 lines)
Files with >800 lines often hide complexity hotspots and discourage tests.
low System graph quality Complexity conf 1.00 Very large file: kafka/consumer/group.py (1347 lines)
Files with >800 lines often hide complexity hotspots and discourage tests.
low System graph quality Complexity conf 1.00 Very large file: kafka/coordinator/base.py (1215 lines)
Files with >800 lines often hide complexity hotspots and discourage tests.
low System graph quality Complexity conf 1.00 Very large file: kafka/coordinator/consumer.py (1224 lines)
Files with >800 lines often hide complexity hotspots and discourage tests.
low System graph quality Complexity conf 1.00 Very large file: kafka/producer/kafka.py (1123 lines)
Files with >800 lines often hide complexity hotspots and discourage tests.
low System graph quality Complexity conf 1.00 Very large file: kafka/producer/transaction_manager.py (1326 lines)
Files with >800 lines often hide complexity hotspots and discourage tests.
low System graph quality Complexity conf 1.00 Very large file: test/consumer/test_coordinator.py (2589 lines)
Files with >800 lines often hide complexity hotspots and discourage tests.
low System graph quality Complexity conf 1.00 Very large file: test/consumer/test_fetcher.py (1792 lines)
Files with >800 lines often hide complexity hotspots and discourage tests.
low System graph quality Complexity conf 1.00 Very large file: test/producer/test_sender.py (1555 lines)
Files with >800 lines often hide complexity hotspots and discourage tests.
low System graph quality Complexity conf 1.00 Very large file: test/producer/test_transaction_manager_mock_broker.py (1508 lines)
Files with >800 lines often hide complexity hotspots and discourage tests.
For AI agents: Voting guide (TP/FP) MCP manifest Stdio wrapper SARIF Integrate Findings queue Vote TP/FP on findings to calibrate the engine.
For AI agents + API integrations
Email me when this repo regresses
Free. We re-scan periodically; new criticals → your inbox. No signup required for the scan itself.
API access

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.