DinGo4DEV opened a new pull request, #51718: URL: https://github.com/apache/airflow/pull/51718
Close [#515225](https://github.com/apache/airflow/issues/51522). Why ----- While using the `MessageQueueTrigger` in Airflow 3.0+, the parameters in the common message queue trigger are not specific enough, leading to potential issues like unclear usage, difficulty in understanding, or unexpected behavior when using it on Kafka What --- This PR introduces the `KafkaMessageQueueTrigger` class to specify the parameters for the message queue trigger to enhance the usability -- 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]
