Hi all, Following the earlier discussion on modernizing the Cassandra Sink (initial thread <https://lists.apache.org/thread/8v7wlx23svvwzb9568fos8lkxobcty7y>), FLIP-533 <https://cwiki.apache.org/confluence/display/FLINK/FLIP-533%3A+Cassandra+Sink+V2> has now been created:
This FLIP proposes a two-phase redesign: - *Phase 1* introduces a modular Sink V2-based Cassandra sink with async write support, type-agnostic configuration, and better integration with Flink's threading and checkpointing model. - *Phase 2* builds on top of Flink 2.1 (FLIP-509), adding partition-aware batching using AsyncSinkWriter, enabling efficient Cassandra writes while avoiding cross-partition batch anti-patterns. Looking forward to hearing your thoughts and suggestions. Thanks, Poorvank
