You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by Mason Chen <ma...@gmail.com> on 2023/06/27 18:56:24 UTC

[ANNOUNCE] Kafka connector code removed from apache/master

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

Re: [ANNOUNCE] Kafka connector code removed from apache/master

Posted by Martijn Visser <ma...@apache.org>.
Thank you for this!

On Tue, Jun 27, 2023 at 8:57 PM Mason Chen <ma...@gmail.com> wrote:

> 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
>