apache/kafka audit

Delivery risk audit on GitHub · Analysed 12 Aug 2026 · GitHub

This delivery risk audit analyses the last 90 days of public commit history for apache/kafka. It identifies files that concentrate bug-fix activity, measures revert frequency as a signal of release instability, and maps contributor spread to highlight knowledge concentration risk. The risk score weights bug-fix commits and reverts for each file, with higher scores indicating files that have required the most corrective attention in the analysed period.

Top Risk Files

File	Risk	Bug Commits	Reverts	Commit touches
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamTaskTest.java	30	3	0	—
share-coordinator/src/main/java/org/apache/kafka/coordinator/share/ShareCoordinatorShard.java	20	2	0	—
share-coordinator/src/test/java/org/apache/kafka/coordinator/share/ShareCoordinatorShardTest.java	20	2	0	—
streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreChangelogReader.java	20	2	0	—
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java	20	2	0	—
streams/src/test/java/org/apache/kafka/streams/processor/internals/StandbyTaskTest.java	20	2	0	—
build.gradle	10	1	0	—
checkstyle/import-control-metadata.xml	10	1	0	—
checkstyle/import-control.xml	10	1	0	—
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java	10	1	0	—
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java	10	1	0	—
clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java	10	1	0	—
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerHeartbeatRequestManager.java	10	1	0	—
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkClient.java	10	1	0	—
clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsMembershipManager.java	10	1	0	—
clients/src/main/java/org/apache/kafka/common/internals/UnsupportedProtocolFieldException.java	10	1	0	—
clients/src/main/java/org/apache/kafka/common/requests/ConsumerGroupHeartbeatRequest.java	10	1	0	—
clients/src/main/java/org/apache/kafka/common/requests/CreateAclsRequest.java	10	1	0	—
clients/src/main/java/org/apache/kafka/common/requests/CreateTopicsRequest.java	10	1	0	—
clients/src/main/java/org/apache/kafka/common/requests/DeleteAclsRequest.java	10	1	0	—

Other audited repositories

• facebook/react
• LiberoNuvola/PRE-RICH-scratch-and-win-game
• kubernetes/kubernetes
• denoland/deno
• opentofu/opentofu
• cilium/cilium
• helm/helm
• argoproj/argo-workflows
• istio/istio
• ansible/ansible
• prometheus/prometheus
• argoproj/argo-cd

All audited repositories →