Create operators for working with Clusters for GCP Apache Kafka

[MaksYermak]

In this PR I have created operators for working with Clusters for GCP Managed Service for Apache Kafka

---

^ Add meaningful description above
Read the Pull Request Guidelines for more information.
In case of fundamental code changes, an Airflow Improvement Proposal (AIP) is needed.
In case of a new dependency, check compliance with the ASF 3rd Party License Policy.
In case of backwards incompatible changes please leave a note in a newsfragment file, named {pr_number}.significant.rst or {issue_number}.significant.rst, in newsfragments.

[VladaZakharova]

hi @potiuk ! Can you please check changes from this PR? :)

[MaksYermak]

@eladkal I have updated the naming for hook and operators. Could you please check PR one more time?

[VladaZakharova]

Hi @eladkal ! Can you please check changes here? Thanks :)

[eladkal]

Hi @eladkal ! Can you please check changes here? Thanks :)

sorry won't get to it in the next 1-2 weeks. Maybe someone else can review

[VladaZakharova]

Hi @eladkal ! Can you please check changes here? Thanks :)

sorry won't get to it in the next 1-2 weeks. Maybe someone else can review

Oh, i see, thanks for reply!

@potiuk Can you please check then? :)

[MaksYermak]

@eladkal @potiuk could you please check this PR again?

[potiuk]

LGTM. @eladkal ?

no time to re-review. leave it for other committers to check

[dstandish]

@MaksYermak do you have any idea what's going on with the kafka messages here?

https://github.com/apache/airflow/actions/runs/13555901653/job/37890520619?pr=46503#step:6:5930

[MaksYermak]

@MaksYermak do you have any idea what's going on with the kafka messages here?

https://github.com/apache/airflow/actions/runs/13555901653/job/37890520619?pr=46503#step:6:5930

Hello @dstandish,
All that I can say is that something happened with kafka cluster, which can be accessible by this url localhost:9092/bootstrap, maybe this cluster does not exist, because this url for me looks like default one. Or maybe consumer and producer functions do not have enough permissions to connect to the cluster. But it's hard for me to say what exactly happened.