Hi all, I would like to inform you that we have removed the Kafka connector code from the Flink main repo. This should reduce the developer confusion of which repo to submit PRs.
Regarding a few nuances, we have kept the Confluent avro format in the main repo. This is because the format is actually connector agnostic. Also, to unblock the code removal for the 1.18 release, we have pinned the connector versions in tests/examples, and these are the followup items [1][2][3] to refactor the main repo code because the Kafka connector dependency is not required in these cases. A big thanks to Gordon, Martjin, and Chesnay who helped review the work from the beginning to the end! [1] https://issues.apache.org/jira/browse/FLINK-32449 [2] https://issues.apache.org/jira/browse/FLINK-32451 [3] https://issues.apache.org/jira/browse/FLINK-32452 Best, Mason
