CVE-2026-111496— Kafka Streams 整数溢出导致线程挂起漏洞
一分钟漏洞结论
影响对象
Apache Software Foundation Apache Kafka
利用判断
尚无明确在野利用证据，仍需结合暴露面评估
建议动作
优先检查厂商安全公告和参考链接中的修复版本；无法立即升级时，限制受影响服务暴露并加强监测。
Kafka Streams 从记录的 timestamp（时间戳）推导其流时间时钟。 在计算下一个标点（punctuation）时间时，采用公式 ，但未执行溢出检查。若某条记录的时间戳等于或接近 ，则流时间会被推进至该值，导致下一个流时间标点发生整数溢出，变为负数。随后， 会将该负时间重新入队，并在持有锁的情况下无限循环处理该时间，致使 停滞。 影响： 单条记录即可触发此问题。受影响的 将停止处理；由于该记录仍保留在主题（topic）中，重启后挂起状态会再次出现。若应用的所有分区均受影响，整个应用将无响应。此问题仅
可能的 ATT&CK 技术 1 AI
T1499 · Endpoint Denial of Service影响版本矩阵 3
| 厂商 | 产品 | 版本范围 | 状态 |
|---|---|---|---|
| Apache Software Foundation | Apache Kafka | 1.1.0≤ 4.1.2 |
affected |
4.2.0≤ 4.2.1 |
affected | ||
4.3.0≤ 4.3.1 |
affected |
获取后续新漏洞提醒
登录后订阅
一、 漏洞 CVE-2026-111496 基础信息
漏洞信息
对漏洞内容有疑问？看看神龙的深度分析是否有帮助！
查看神龙十问 ↗
尽管我们使用了先进的大模型技术，但其输出仍可能包含不准确或过时的信息。神龙努力确保数据的准确性，但请您根据实际情况进行核实和判断。
Vulnerability Title
Apache Kafka: Kafka Streams StreamThread hang from integer overflow in stream-time punctuation
来源: CVE Program / CVE List V5
Vulnerability Description
Kafka Streams derives its stream-time clock from record timestamps. PunctuationSchedule.next() computed the next punctuation time as timestamp + (intervalsMissed + 1) * interval with no overflow check. A record with a timestamp at or near Long.MAX_VALUE advances stream time to that value, so the next stream-time punctuation overflows to a negative time. PunctuationQueue then re-queues that time and loops on it indefinitely while holding a lock, stalling the StreamThread.
Impact:
A single record is enough. The affected StreamThread stops processing, and because the record stays in the topic the hang returns on restart; an application whose partitions are all affected becomes unresponsive. Only the Streams application is affected, not the brokers or the cluster. Triggering it needs write access to a source topic whose topology uses stream-time punctuation, and a broker that stores the record: brokers from Apache Kafka 4.0.0 reject such a timestamp by default (log.message.timestamp.after.max.ms, one hour), so it is reachable only on older brokers or where that bound has been relaxed.
Mitigation:
Upgrade Kafka Streams to 4.2.2, 4.3.2, or 4.4.0. As defense in depth, keep log.message.timestamp.after.max.ms bounded on source topics and restrict write access to them.
Resolution:
From Apache Kafka 4.2.2, 4.3.2, and 4.4.0: the next punctuation time is computed with overflow-checked arithmetic (clamped to Long.MAX_VALUE), and a rescheduled punctuation is re-queued only when its time moves forward.
来源: CVE Program / CVE List V5
CVSS Information
N/A
来源: CVE Program / CVE List V5
Vulnerability Type
整数溢出或超界折返
来源: CVE Program / CVE List V5
受影响产品
| 厂商 | 产品 | 影响版本 | CPE | 订阅 |
|---|---|---|---|---|
| Apache Software Foundation | Apache Kafka | 1.1.0 ~ 4.1.2 | - |
|
二、漏洞 CVE-2026-111496 的公开POC
| # | POC 描述 | 源链接 | 神龙链接 |
|---|
AI 生成 POC
高级
未找到公开 POC。
登录以生成 AI POC三、漏洞 CVE-2026-111496 的情报信息
请登录查看更多情报信息。
同批安全公告 · Apache Software Foundation · 2026-10-28 · 共 12 条
| CVE-2026-114349 | Apache Kafka 解压缩无界内存分配拒绝服务漏洞 | |
| CVE-2026-112375 | Apache Kafka 任意文件读取漏洞 | |
| CVE-2026-116593 | Apache Kafka 配置值通过验证 REST API 泄露 | |
| CVE-2026-115644 | Apache Kafka Connect Admin 认证绕过漏洞 | |
| CVE-2026-111551 | Apache Kafka 拒绝服务漏洞 | |
| CVE-2026-111115 | Apache Kafka 灵活协议解析内存耗尽漏洞 | |
| CVE-2026-111108 | Apache Kafka 2.5.0 协议读取器内存耗尽漏洞 | |
| CVE-2026-111073 | Apache Kafka PushTelemetry 拒绝服务漏洞 | |
| CVE-2026-110985 | Apache Kafka 未配置 JWKS 时跳过 JWT 签名验证漏洞 | |
| CVE-2026-110952 | Apache Kafka 默认未验证 JWT 签发者和受众漏洞 | |
| CVE-2026-83525 | Kafka KRaft 控制器远程拒绝服务漏洞 |