Apache Airflow Apache Kafka provider: Connection-editor remote code execution on the Scheduler via Kafka connection callback configuration

{
  "id": "f2b47bcaee912ab903d1d7a802e1a0cff9361d9c28e595687db5329507ac4dc4",
  "url": "https://osv.dev/vulnerability/CVE-2026-86792",
  "method": "structured",
  "payload": {
    "kind": "advisory",
    "title": "Apache Airflow Apache Kafka provider: Connection-editor remote code execution on the Scheduler via Kafka connection callback configuration",
    "summary": "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 via `import_string`, with no allowlist, and hand them to the confluent-kafka client which invokes them. Deployments that have enabled the Kafka event producer — `dag_run_events_enabled` or `task_instance_events_enabled`, both disabled by default — build that client inside the scheduler process, so a user whose only privilege is editing Airflow connections gains arbitrary code execution in the control plane; the Airflow security model limits connection-configuration users to code execution on workers, not the scheduler. Deployments using Google Managed Kafka are not affected, because that code path overwrites any user-supplied `oauth_cb`; plain brokers and Amazon MSK are exposed. Users are recommended to upgrade to apache-airflow-providers-apache-kafka 2.0.0 or later, which adds an allowlist configuration option for connection-string callbacks.",
    "evidence": "osv:CVE-2026-86792",
    "products": [],
    "severity": "high",
    "structured": {
      "id": "CVE-2026-86792",
      "aliases": [
        "CVE-2026-86792",
        "PYSEC-2026-3986"
      ],
      "metrics": [
        {
          "type": "CVSS_V3",
          "score": "CVSS:3.1/AV:N/AC:L/PR:L/UI:N/S:U/C:H/I:H/A:H"
        }
      ],
      "affected": [
        {
          "ranges": [
            {
              "repo": "https://github.com/apache/airflow",
              "type": "GIT",
              "events": [
                {
                  "introduced": "9dcbe41dd4c1ac265c51ad9a932af68088e50984"
                },
                {
                  "fixed": "8217db8cb4b1ff302c5cf8662477ac00f701e78c"
                }
              ],
              "database_specific": {
                "extracted_events": [
                  {
                    "range": [
                      {
                        "introduced": "1.15.0"
                      },
                      {
                        "fixed": "2.0.0"
                      }
                    ],
                    "source": "AFFECTED_FIELD",
                    "strategy": "StandardRange"
                  },
                  {
                    "cpe": "cpe:2.3:a:apache:apache-airflow-providers-apache-kafka:*:*:*:*:*:*:*:*",
                    "range": [
                      {
                        "introduced": "1.15.0"
                      },
                      {
                        "fixed": "2.0.0"
                      }
                    ],
                    "source": "CPE_RANGE"
                  }
                ]
              }
            }
          ],
          "database_specific": {
            "source": "https://storage.googleapis.com/cve-osv-conversion/osv-output/CVE-2026-86792.json"
          }
        }
      ],
      "modified": "2026-10-28T02:30:32.363659897Z",
      "provider": "osv",
      "references": [
        "https://pypi.python.org",
        "https://github.com/CVEProject/cvelistV5/tree/main/cves/2026/86xxx/CVE-2026-86792.json",
        "https://lists.apache.org/thread/jl4gpok02313yh3rvtvj8qbo11c6zpr2",
        "https://lists.apache.org/thread/jl4gpok02313yh3rvtvj8qbo11c6zpr2?users@airflow.apache.org",
        "https://nvd.nist.gov/vuln/detail/CVE-2026-86792",
        "https://github.com/apache/airflow/pull/72208"
      ],
      "provider_metadata": {
        "cwe_ids": [
          "CWE-470"
        ],
        "cna_assigner": "apache",
        "osv_generated_from": "https://github.com/CVEProject/cvelistV5/tree/main/cves/2026/86xxx/CVE-2026-86792.json"
      }
    },
    "related_cves": [
      {
        "value": "CVE-2026-86792",
        "evidence": "/id"
      }
    ],
    "security_relevant": true,
    "severity_evidence": "/severity/0/score"
  },
  "source_id": "core-osv",
  "document_id": 499587,
  "published_at": "2026-09-16T09:08:20.184+00:00"
}