Read 2026-10-23
apache/kafka: technical due diligence, read from its repository
What Borehole read in apache/kafka's code and history at 71312a1: its licence, security advisories, releases, review practice, tests, dependencies and operations. Every finding cites the file and line it rests on. The full report also covers the team and asks the questions the code cannot answer.
| Dimension | Rating |
|---|---|
| Architecture & Codebase — including AI provenance | adequate |
| Engineering Process & SDLC Maturity | strong |
| Product & Engineering Maturity | strong |
| Security & Reliability Posture | adequate |
| Observability & Operations | adequate |
| Fit with the Acquirer | not assessable |
What the repository says
- Releases are cut from another branch than the one surveyed
LICENSE: Relicensed: Apache-2.0 → CDDL-1.0 (2016-03-03) → EPL-2.0 (2020-07-28) → Apache-2.0 (2021-04-06)AGENTS.md:2: names Apache Software FoundationAGENTS.md:132: states a policy on AI-generated contributions
Architecture & Codebase — including AI provenance
adequategroup-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java is 10,189 lines, 90× this codebase's median file
adequateThe median source file here is 113 lines. 75 files exceed 1,130 lines, the largest being 10,189. Size is not a defect on its own — some problems genuinely live in one place — but these are where merge conflicts, review fatigue and single-owner knowledge concentrate, and they are the first thing that slows an inheriting engineer down.
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:1 — 10,189 lines (90× median) |
clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java:1 — 5,388 lines (47× median) |
core/src/main/scala/kafka/server/KafkaApis.scala:1 — 4,405 lines (38× median) |
raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java:1 — 4,186 lines (37× median) |
core/src/main/java/kafka/server/share/SharePartition.java:1 — 3,604 lines (31× median) |
1 base image floats: no version, or `latest`
adequate1 of 6 `FROM` lines in product Dockerfiles name an image without a version, or with `latest`. Each build pulls whatever the registry serves that day, so the image that ships can change without a commit, and last month's build cannot be reproduced. Pin a version, or a digest.
docker/native/Dockerfile:50 — base image without a version |
Engineering Process & SDLC Maturity
strongNo finding.
Product & Engineering Maturity
strong39 files still carry code deprecated more than two years ago
adequate39 files were marked deprecated over two years ago and still are, the oldest since Apr 2019. A deprecation is a promise to remove. Ask what still depends on these, and whether removing them is scheduled.
clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java — deprecated since Apr 2019 |
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorRecordContext.java — deprecated since Apr 2019 |
streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java — deprecated since May 2019 |
streams/src/main/java/org/apache/kafka/streams/kstream/JoinWindows.java — deprecated since May 2019 |
clients/src/main/java/org/apache/kafka/clients/admin/Admin.java — deprecated since Jul 2019 |
Releases are cut from another branch than the one surveyed
adequateThe newest release, 4.4.0, is not on the branch this survey read; the newest pre-release on it is 0.8.0-beta1. The shipped product may differ from what this report describes. Survey the release branch too.
| tag 4.4.0 |
Security & Reliability Posture
adequate1 credential-shaped string in the tree sit in tests, examples, documentation or local development settings
adequateStrings shaped like credentials appear only where fakes are usual: test fixtures, examples, documentation, placeholders and local stacks. They are almost always fakes. Ask someone to confirm that none of them works anywhere, because a real key in a development file is still a real key.
| JWT, where fakes are usual |
13 dependencies float, and no lockfile is committed
adequateDependency versions are declared as ranges and no lockfile is committed, so a build today does not necessarily produce what a build last month produced. That matters twice over in a transaction: the thing being bought cannot be reproduced exactly, and a compromised upstream release arrives without anyone choosing to take it.
.github/scripts/requirements.txt:17 — ~=6.0 |
docker/requirements.txt:15 — any version |
docker/requirements.txt:16 — any version |
docker/requirements.txt:17 — any version |
tests/docker/requirements.txt:16 — any version |
Relicensed: Apache-2.0 → CDDL-1.0 (2016-03-03) → EPL-2.0 (2020-07-28) → Apache-2.0 (2021-04-06)
adequateThe root licence changed 3 time(s). Code taken under earlier terms stays under them; check which terms any fork or customer relied on.
11 advisories against this project in the last 24 months, 7 high or critical
adequateThe newest was published on 2026-09-16. A project that publishes advisories is telling its users about its fixes, and the count and pace say how much security work it carries. Whether 11 of them are fixed in the code you ship could not be told from this history. Answer lives in: the release you run, set against each fixed version. The record is incomplete: NVD: 37 records name kafka with nothing tying them to this repository (CVE-2016-10693, CVE-2023-29471, CVE-2023-34040, …).
| 2026-09-16: CVE-2026-86792 (high): Apache Airflow Apache Kafka provider versions 1.15.0 before 2.0.0 resolve dotted-path strings found in a Kafka connection's `extra` field into Python callables |
| 2026-06-02: CVE-2026-41115 (moderate): An improper authorization vulnerability has been identified in Apache Kafka. The implementation of the CONSUMER_GROUP_DESCRIBE (69) API validates the DESCRIBE |
| 2026-04-20: CVE-2026-33557 (critical): A possible security vulnerability has been identified in Apache Kafka. By default, the broker property `sasl.oauthbearer.jwt.validator.class` is set to `org.ap |
| 2026-04-20: CVE-2026-33558 (moderate): Information exposure vulnerability has been identified in Apache Kafka. The NetworkClient component will output entire requests and responses information in th |
| 2026-04-07: CVE-2026-35554 (high): A race condition in the Apache Kafka Java producer client’s buffer pool management can cause messages to be silently delivered to incorrect topics. When a prod |
Observability & Operations
adequateNo structured logging library is in use
adequateNothing references a structured logging library. Logs that are written to be read by a person are not searchable by a machine, which means incident response here is proportional to how well someone remembers the codebase rather than to what the tooling can find.
| searched 7,159 files for 10 structured logging libraries; 0 matched |
No error reporter is wired in
adequateNothing in the service initialises an error reporter (Sentry, Rollbar, Bugsnag, Honeybadger or an APM agent). An exception in production reaches a person only if someone is reading the logs, which usually means a customer reports it first.
| no error reporter initialised |
Fit with the Acquirer
not assessableNot rated: structurally not assessable from a repository.
Read more, or read your own
The full report on apache/kafka: every dimension, the questions for the room, and the audit log.
Survey a repository: free on public repositories. Private code is read on your own machine by a collector whose source you can read first.