Skip to main content

kafka-python CVE-2026-10143

| EUVDEUVD-2026-36128 HIGH
Uncontrolled Resource Consumption (CWE-400)
2026-06-10 VulnCheck GHSA-2jcm-hq8r-84wx
8.7
CVSS 4.0 · Vendor: VulnCheck
View

Attack ChainAIDerived

Hypothetical attack flow derived from CVE metadata – not a confirmed exploit chain

  1. Access
    Position rogue/MITM Kafka broker
  2. Delivery
    Client opens SASL SCRAM connection
  3. Exploit
    Broker returns huge PBKDF2 iteration count
  4. Execution
    Client calls hashlib.pbkdf2_hmac on event loop
  5. Persist
    CPU-bound hash blocks all I/O callbacks
  6. Impact
    Heartbeats miss, consumer evicted, reconnect loop

Vulnerability Assessment

Weakness
CWE
OWASP Top 10:2025
A06:2025 - Insecure Design
ASVS 5.0
V2 - Validation and Business Logic Resource consumption limits
MITRE ATT&CK

1 technique across 1 tactic: Impact

The technique list with ATT&CK links and the kill-chain view is part of the Basic plan and up.

Exploitation Conditions

Exploitation requires the client to initiate a SASL SCRAM-SHA-256 or SCRAM-SHA-512 handshake against an attacker-controlled or MITM-intercepted broker endpoint - clients using PLAIN, GSSAPI/Kerberos, OAUTHBEARER, or no SASL at all are not on this code path. The attacker does not need credentials, user interaction, or any prior foothold on the client, but they must be able to deliver a forged server-first-message, which in practice means either operating a rogue broker the client is configured to reach (e.g. via a poisoned bootstrap.servers list, DNS hijack, or ARP spoof on the broker network) or breaking TLS trust when SASL_SSL is in use. Impact is limited to availability: the client process freezes its event loop and disconnects, but no data is read, written, or leaked, and the stall ends when the process is restarted.

Impact

The CVSS 4.0 vector AV:N/AC:L/AT:N/PR:N/UI:N/VC:N/VI:N/VA:H/SC:N/SI:N/SA:N correctly captures a high-availability-only impact reachable without authentication or user interaction, yielding the 8.7 score; confidentiality and integrity are untouched because the malicious broker never completes the SCRAM exchange and gains no key material. The realistic prerequisite is non-trivial, however: the attacker must either operate a rogue broker that the client willingly connects to, or be positioned to MITM the bootstrap connection - which usually means TLS is disabled or trust is misconfigured, since SCRAM is typically tunnelled over SASL_SSL. There is no CISA KEV listing and no EPSS score was provided, and no public exploit identified at time of analysis, so this is best treated as a credible supply-chain/MITM hardening fix rather than an actively exploited issue; the impact when triggered is real, though - full client-loop stall affecting producers, consumers, admin, and heartbeats simultaneously.

Exploit ScenarioDerived

An attacker who can intercept the TCP handshake to the Kafka bootstrap broker (untrusted network, compromised DNS, or rogue broker advertised via a misconfigured listener) terminates the SCRAM handshake with a server-first-message containing an iteration count in the billions. The kafka-python client calls hashlib.pbkdf2_hmac() with that count on its main event loop thread and hangs indefinitely, stalling producer sends, consumer polls, admin operations, and heartbeats until the consumer is evicted from its group. No public PoC is referenced, but the fix diff makes the trigger straightforward to reconstruct.

This Week Schedule remediation this week. Why: HIGH severity (CVSS 7.0-8.9).
Patch available 0.1% exploitation probability (EPSS)

Get an e-mail when this CVE is exploited, patched or re-scored. Free account.

Alert me

AnalysisAIv3 – Jun 10, 2026

Denial of service in kafka-python versions prior to 2.3.2 allows a malicious or man-in-the-middle Kafka broker to freeze the client's event loop during SCRAM authentication by returning an excessive PBKDF2 iteration count. Because ScramClient.process_server_first_message() forwards the broker-supplied value directly to hashlib.pbkdf2_hmac() without bounds checking, producers, consumers, admin clients, and group heartbeats all stall, leading to consumer-group eviction and reconnect loops. No public exploit identified at time of analysis, though VulnCheck has published a vendor-style advisory and an upstream patch has been merged.

Earlier versions of this analysis (2)
v2 Jun 10, 2026 - 22:31 cvss changed CVSS 8.7

Denial-of-service in kafka-python versions prior to 2.3.2 lets a malicious or man-in-the-middle Kafka broker freeze a client's event loop during SCRAM authentication by returning an excessively large PBKDF2 iteration count, halting producer sends, consumer polls, admin operations, and heartbeats. The flaw was reported by VulnCheck, a vendor patch is available, and no public exploit identified at time of analysis; CVSS 4.0 rates it 8.7 due to high availability impact with no authentication or user interaction required.

v1 Jun 10, 2026 - 21:17 CVSS 7.5

Denial of service in kafka-python versions prior to 2.3.2 lets a malicious or machine-in-the-middle Kafka broker freeze the Python client's event loop during SCRAM authentication by returning an excessively large PBKDF2 iteration count. The unvalidated value is fed directly into hashlib.pbkdf2_hmac(), stalling producers, consumers, admin clients, and heartbeats, with no public exploit identified at time of analysis.

RemediationAI

Vendor-released patch: upgrade kafka-python to 2.3.2 or later, which adds an explicit upper bound on the broker-supplied SCRAM iteration count before invoking hashlib.pbkdf2_hmac() and also introduces a receive_message_max_bytes frame-size guard (commit 6e4831444f972d169cdd11f5c8d50333cea3f19b and PRs https://github.com/dpkp/kafka-python/pull/3019 and https://github.com/dpkp/kafka-python/pull/3026). Where an immediate upgrade is not possible, restrict clients to known-good brokers by pinning bootstrap_servers to internal addresses and enforcing SASL_SSL with hostname verification and a private CA so a rogue or MITM broker cannot present itself - the trade-off is operational, requiring strict certificate and DNS hygiene. As a defense-in-depth measure, run the SCRAM-authenticating client in a dedicated process or thread pool so a stalled PBKDF2 call cannot block unrelated event loops, accepting the added complexity and slight latency.

Affected VersionsENISA

kafka-python 0 <2.3.2

Affected Packages

pypi kafka-python fix: 2.3.2

Source: OSV (Open Source Vulnerabilities)

Affects your stack

Affects 1 package in pypi

Checking this CVE against your own stacks and servers is part of the Basic plan and up.

Technical ContextAI · show details

kafka-python is a pure-Python Apache Kafka client library (cpe:2.3:a:dana_powers:kafka-python) used to build producers, consumers, and admin tooling against Kafka brokers. SCRAM (Salted Challenge Response Authentication Mechanism, RFC 5802) negotiates a session key by having the client run PBKDF2-HMAC over the password using a salt and iteration count advertised by the server in the server-first-message. The library implements that step in kafka/scram.py, where the iteration count parsed from the broker frame is trusted and passed straight into hashlib.pbkdf2_hmac(), a synchronous, CPU-bound C routine that scales linearly with the iteration count. This is a classic CWE-400 Uncontrolled Resource Consumption: an unvalidated external value drives an unbounded amount of work on a single thread, blocking the asyncio/selector loop that also drives I/O, fetch, heartbeat, and timer callbacks.

Know when Python gets its next vulnerability

  • Watch products and get an email when something new is published
  • Check this CVE against your own stack and servers
  • Exploit and PoC references, threat intelligence from 22 sources

No credit card · 7-day full trial

Severity by source

Vendor (VulnCheck) PRIMARY 8.7 HIGH
CVSS:4.0/AV:N/AC:L/AT:N/PR:N/UI:N/VC:N/VI:N/VA:H/SC:N/SI:N/SA:N
vuln.today AI 5.9 MEDIUM

Network-reachable and unauthenticated, but requires attacker to control or MITM the broker connection (AC:H); only availability is impacted via event-loop stall.

3.1 AV:N/AC:H/PR:N/UI:N/S:U/C:N/I:N/A:H
4.0 AV:N/AC:H/AT:N/PR:N/UI:N/VC:N/VI:N/VA:H/SC:N/SI:N/SA:N
SUSE HIGH
Red Hat 7.5 HIGH

Primary rating from Vendor (VulnCheck).

CVSS VectorVendor: VulnCheck

Attack Vector
Network
Attack Complexity
Low
Attack Requirements
None
Privileges Required
None
User Interaction
None
Vulnerable system: Confidentiality
None
Vulnerable system: Integrity
None
Vulnerable system: Availability
High
Subsequent system: Confidentiality
None
Subsequent system: Integrity
None
Subsequent system: Availability
None

Lifecycle Timeline

3
Analysis Updated
Jun 10, 2026 - 22:32 vuln.today
v3 - CVSS changed
Analysis Updated
Jun 10, 2026 - 22:31 vuln.today
v2 - CVSS changed
CVSS changed
Jun 10, 2026 - 22:22 NVD
7.5 (HIGH) 8.7 (HIGH)

DescriptionCVE.org

kafka-python prior to 2.3.2 contains a denial-of-service vulnerability in SCRAM authentication handling that allows a malicious or machine-in-the-middle broker to freeze the client event loop by supplying an excessively large iteration count. In scram.py, ScramClient.process_server_first_message() passes the broker-controlled SCRAM iteration count directly to hashlib.pbkdf2_hmac() without validation, blocking producer sends, consumer polls, admin operations, and heartbeats, which can cause consumer group eviction and repeated reconnect failures.

Blast Radius

ecosystem impact
† from your stack dependencies † transitive graph · vuln.today resolves 4-path depth
  • 2 pypi packages depend on kafka-python (2 direct, 0 indirect)

Ecosystem-wide dependent count for version 2.3.2.

Executive ViewAI

Why It Matters

kafka-python versions before 2.3.2 contain a denial-of-service vulnerability triggered during SCRAM authentication that freezes client event loops; no public exploit identified at time of analysis. This impacts all client types (producers, consumers, admin tools) and directly threatens the availability and reliability of message-driven architectures and data pipelines. With a vendor patch available, organizations should prioritize upgrading to kafka-python 2.3.2+ within 30 days to eliminate this application-layer availability risk.

Business Impact: High
Compensating Controls

Apply vendor patch: kafka-python 2.3.2 or later.

Threat Intelligence Overview

EPSS Score
0.1%
Top 79% exploitable
Threat Intel
1
1 source
Social Media
1
Sightings
Data Quality
8 sources
Confidence: High
EUVD NVD CVE.org EPSS Vulnrichment GHSA Vendor CIRCL GitHub VulDB

How this decision was reached

The engine reads each signal below and applies a fixed list of rules from top to bottom. The first rule that matches sets the recommended action – like a statement, every line is shown.

SignalValue
Severity HIGH
CISA KEV No
Public POC No
EPSS 0.1%
Patch available Yes
Active threat No
Deciding rule
HIGH severity (CVSS 7.0-8.9)
What every action level means
Emergency Immediate action required. Criteria: CRITICAL + in CISA KEV (actively exploited) without patch, OR CRITICAL + EPSS > 30% without patch, OR CRITICAL + active threat signals without patch.
Act Now Prioritize within 24-48h. Criteria: in KEV with patch available, OR CRITICAL + public POC, OR HIGH + EPSS > 10%, OR CRITICAL + active threat, OR any CRITICAL severity.
This Week Schedule remediation this week. Criteria: HIGH severity (CVSS 7.0-8.9). Patch within normal change window.
This Month Plan within 30 days. Criteria: MEDIUM severity (CVSS 4.0-6.9), lower exploitation probability. Include in regular patch cycle.
Monitor Track and reassess. Criteria: LOW severity (CVSS 0.1-3.9), minimal exploitation risk. No immediate action needed.

SSVC AssessmentENISA

SSVC Decision
Scheduled
Exploitation
None
System Exposure· derived
Open
Automatable
Yes
Human Impact
High
Technical Impact
Partial

Priority Score

44
Low Medium High Critical
KEV: 0
EPSS: 0
CVSS: +44
PoC: 0
Weaponized: 0
Threat intel: 0
Gov advisory: 0

Attack Technique

Denial of Service attacks render applications or systems unavailable by overwhelming resources or triggering failure conditions.

More in Python

View all
CVE-2025-24016 CRITICAL POC
9.9 Feb 10

Wazuh SIEM platform versions 4.4.0 through 4.9.0 contain an unsafe deserialization vulnerability in the DistributedAPI t

CVE-2025-27520 CRITICAL POC
9.8 Apr 04

BentoML version 1.4.2 and earlier contains an unauthenticated remote code execution vulnerability through insecure deser

CVE-2025-2945 CRITICAL POC
9.9 Apr 03

pgAdmin 4 contains critical remote code execution vulnerabilities in the Query Tool download and Cloud Deployment endpoi

CVE-2013-5093 MEDIUM POC
6.8 Sep 27

The renderLocalView function in render/views.py in graphite-web in Graphite 0.9.5 through 0.9.10 uses the pickle Python

CVE-2025-32375 CRITICAL POC
9.8 Apr 09

BentoML is a Python library for building online serving systems optimized for AI apps and model inference. Rated critica

CVE-2014-0224 HIGH POC
7.4 Jun 05

OpenSSL before 0.9.8za, 1.0.0 before 1.0.0m, and 1.0.1 before 1.0.1h does not properly restrict processing of ChangeCiph

CVE-2024-21644 HIGH POC
7.5 Jan 08

pyLoad download manager version prior to 0.5.0b3.dev77 exposes the Flask SECRET_KEY through an unauthenticated endpoint.

CVE-2026-33017 CRITICAL POC
9.3 Mar 17

Langflow (a visual LLM pipeline builder) contains a critical unauthenticated code execution vulnerability (CVE-2026-3301

CVE-2017-9462 HIGH POC
8.8 Jun 06

In Mercurial before 4.1.3, "hg serve --stdio" allows remote authenticated users to launch the Python debugger, and conse

CVE-2026-49869 CRITICAL POC
10.0 Jun 26

Unauthenticated remote code execution affects Kestra OSS (the open-source event-driven orchestration platform) prior to

CVE-2026-39987 CRITICAL POC
9.3 Apr 08

Unauthenticated remote code execution in Marimo ≤0.20.4 allows attackers to execute arbitrary system commands via the `/

CVE-2024-21645 MEDIUM POC
5.3 Jan 08

pyLoad is the free and open-source Download Manager written in pure Python. Rated medium severity (CVSS 5.3), this vulne

Vendor StatusVendor

SUSE

Severity: Important

This site uses cookies essential for authentication and security. No tracking or analytics cookies are used. Privacy Policy