Hi Marco, Thanks for volunteering! It would be great if you could help with contributions, they are much appreciated.
The plan is indeed to move connectors to its own individual repository, for Cassandra that most likely would be something like https://github.com/apache/flink-connector-cassandra. That is pending the availability of some generic stuff (like testing framework). Until that move is made, contributions for improving the Cassandra connector are still accepted. Regarding the priorities, I think you're spot on. With regards to which Cassandra version should be supported, I'm interested in what you think on that, also depending on the backwards compatibility of Cassandra itself. For example with Elasticsearch, the decision was made to follow Elastic's support policy, meaning we support the latest major version (7.*) and the latest minor of the major before that (6.8.*). We can also sync on the current Cassandra related tickets and clean-up/prioritize those. Best regards, Martijn On Mon, 31 Jan 2022 at 15:23, Marco Zühlke <mzueh...@apache.org> wrote: > Hi, > > just discovered the voting thread and wanted to raise my hand to in an > attempt to maintain the Apache Cassandra connector. At work Kafka -> Flink > -> Cassandra is a very common usage pattern for me. > > From other ongoing threads I got that the connectors would be removed from > main repository anyways and in the future maintained in the > https://github.com/apache/flink-connectors repo, right ? > > From the listed topic I think that the adopting the new ASync API combined > with probably support for Cassandra 4.0 are the most pressing issue. > > Best reagards, > Marco > > On 2022/01/21 08:22:42 Martijn Visser wrote: > > Hi everyone, > > > > We're looking for community members, who would like to maintain Flink's > > Cassandra connector [1] going forward. The connector currently is only > > available as a Sink for DataStream users and the original contributors > are > > unable to work on further improvements. > > > > An overview of some of the things that are missing on the Cassandra > > connector: > > > > * Not using the Unified Sink API [2] or ASync API [3] > > * Can't be used in the Table API / SQL > > * Not available as a Source > > * Not available for Lookups > > * Not using the latest supported versions for Cassandra > > > > If you would like to take on this responsibility or can join this effort > in > > a supporting role, please reach out! > > > > If we can't find maintainers for this connector, I'll open up a vote to > > deprecate this connector and remove it. > > > > I'm looking forward to your thoughts. > > > > Best regards, > > > > Martijn Visser > > https://twitter.com/MartijnVisser82 > > > > [1] > > > https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/datastream/cassandra/ > > [2] > > > https://cwiki.apache.org/confluence/display/FLINK/FLIP-143%3A+Unified+Sink+API > > [3] > https://cwiki.apache.org/confluence/display/FLINK/FLIP-171%3A+Async+Sink > > >
