CVE-2026-86792

Le versioni 1.15.0 di Apache Airflow Apache Kafka provider prima della 2.0.0 risolvono le stringhe dotted-path trovate nel campo `extra` di una connessione Kafka in callables Python tramite `import_string`, senza alcuna whitelist, e le passano al client confluent-kafka che le invoca. Le distribuzioni che hanno abilitato il producer di eventi Kafka — `dag_run_events_enabled` o `task_instance_events_enabled`, entrambi disabilitati di default — costruiscono quel client all’interno del processo scheduler, quindi un utente il cui unico privilegio è modificare le connessioni Airflow ottiene esecuzione di codice arbitrario nel piano di controllo; il modello di sicurezza di Airflow limita gli utenti di configurazione delle connessioni all’esecuzione di codice sui worker, non sul scheduler. Le distribuzioni che utilizzano Google Managed Kafka non sono soggette a questa vulnerabilità, perché quel percorso di codice sovrascrive qualsiasi `oauth_cb` fornito dall’utente; i broker plain e Amazon MSK sono invece esposti. Si raccomanda agli utenti di aggiornare a apache-airflow-providers-apache-kafka 2.0.0 o versioni successive, che introduce un’opzione di configurazione whitelist per i callback delle stringhe di connessione.