arnoldmr01 commented on PR #69000: URL: https://github.com/apache/airflow/pull/69000#issuecomment-5685048029
@jason810496 The way we consume messages from an MSK topic still uses the standard Kafka protocol. Therefore, I think we do not need a dedicated MSK event trigger and can reuse `KafkaMessageQueueTrigger` https://github.com/apache/airflow/blob/49674b776df40562e47b60693958293b734199ce/providers/apache/kafka/src/airflow/providers/apache/kafka/triggers/await_message.py#L111-L120 https://github.com/apache/airflow/blob/49674b776df40562e47b60693958293b734199ce/providers/apache/kafka/src/airflow/providers/apache/kafka/hooks/base.py#L147-L184 When KafkaBaseHook._build_config() detects an MSK bootstrap hostname, `_maybe_add_msk_iam_oauth()` automatically injects the MSK IAM `oauth_cb` I may be missing something here. Please let me know if I’ve misunderstood anything -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
