The GitHub Actions job "Tests (AMD)" on airflow.git/main has failed.
Run started by GitHub user potiuk (triggered by potiuk).

Head commit for run:
ca967b9c047260f9378308b252d588b5d1b91d3a / Tim <[email protected]>
Add Amazon MSK IAM (OAUTHBEARER) support to Apache Kafka provider (#69427)

The Kafka provider already injects an ``oauth_cb`` token callback for Google
Managed Kafka based on the bootstrap servers hostname. Amazon MSK offers the
same OAUTHBEARER-based IAM authentication (and MSK Serverless supports IAM
only), but there was no equivalent branch, forcing users to wire the token
signer by hand.

This adds a symmetric branch: when the bootstrap servers point at an Amazon
MSK endpoint (``*.kafka.<region>.amazonaws.com`` or
``*.kafka-serverless.<region>.amazonaws.com``, including ``.cn`` regions) and
``sasl.mechanism`` is ``OAUTHBEARER``, the hook derives the AWS region from the
hostname and installs an ``oauth_cb`` backed by
``aws_msk_iam_sasl_signer.MSKAuthTokenProvider``. The callback converts the
signer's millisecond expiry to the seconds expected by confluent-kafka. An
explicit user-provided ``oauth_cb`` is never overwritten, and a missing signer
library raises ``AirflowOptionalProviderFeatureException`` pointing at the new
``msk`` extra.

Report URL: https://github.com/apache/airflow/actions/runs/28875861812

With regards,
GitHub Actions via GitBox


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to