Kafka Operators - Add context to ConsumeFromTopicOperator's apply_function

[sheinbergon]

---

• Support passing AF context to apply_function when using ConsumeFromTopicOperator

[boring-cyborg[bot]]

Congratulations on your first Pull Request and welcome to the Apache Airflow community! If you have any issues or are unsure about any anything please check our Contributors' Guide (https://github.com/apache/airflow/blob/main/contributing-docs/README.rst) Here are some useful points:

• Pay attention to the quality of your code (ruff, mypy and type annotations). Our pre-commits will help you with that.
• In case of a new feature add useful documentation (in docstrings or in docs/ directory). Adding a new operator? Check this short guide Consider adding an example DAG that shows how users should use it.
• Consider using Breeze environment for testing locally, it's a heavy docker but it ships with a working Airflow and a lot of integrations.
• Be patient and persistent. It might take some time to get a review or get the final approval from Committers.
• Please follow ASF Code of Conduct for all communication including (but not limited to) comments on Pull Requests, Mailing list and Slack.
• Be sure to read the Airflow Coding style.
• Always keep your Pull Requests rebased, otherwise your build might fail due to changes not related to your commits. Apache Airflow is a community-driven project and together we are making it better 🚀. In case of doubts contact the developers at: Mailing List: dev@airflow.apache.org Slack: https://s.apache.org/airflow-slack

[sheinbergon]

What will happen when someone updates the provider version, and has an apply_function callable that processes a single argument (without **kwargs)?

IMHO it will fail, so we need to create a new major release or make it backward compatible.

I guess I can use inspect to test if the callbable expects that context and decide to call it or not based on the inspection result. Would that be preferable in your opinion?