CVE-2026-42316kafka-sink-azure-kusto是微软官方提供的Azure Data Explorer连接器。在5.2.3版本之前,该插件在处理`kusto.tables.topics.mapping`配置时存在安全缺陷,未能对用户控制的值进行清理。攻击者若拥有修改连接器配置的权限,可利用该漏洞注入KQL元字符,在连接器服务主体上下文中执行任意管理命令,导致数据库架构被篡改或策略被修改。
该漏洞的根本原因是kafka-sink-azure-kusto插件在构建KQL(Kusto Query Language)管理命令时,缺乏对用户输入的严格过滤。具体而言,代码直接使用`String.formatted(...)`方法将配置项`kusto.tables.topics.mapping`中的`db`、`table`、`mapping`和`format`字段动态拼接到预定义的命令模板中(例如`FETCH_TABLE_COMMAND`和`FETCH_TABLE_MAPPING_COMMAND`)。攻击者若具备修改Kafka Connect连接器配置的高权限,即可在上述字段中嵌入KQL元字符(如分号`;`、管道符`|`或单引号`'`)。通过精心构造的输入,攻击者能够绕过原有的命令逻辑,注入并执行任意KQL管理命令。这种注入使得攻击者能够以连接器的服务主体身份,对目标Azure Data Explorer数据库进行架构枚举、摄取映射篡改或修改流与保留策略等破坏性操作,严重威胁数据的完整性与可用性。