Hi Fink Devs, Our team has been working on migrating various data pipelines to Flink to leverage the benefits of exactly-once processing, checkpointing, and stateful computing. We have several use cases built around the AWS SQS Service. For this migration, we have developed an SQS Source Connector, which enables us to run both stateless and stateful Flink-based jobs.
We believe that this SQS Source Connector would be a valuable addition to the existing connector set. Therefore, we propose a FLIP to include it. For more information, please refer to the FLIP document. https://docs.google.com/document/d/1lreo27jNh0LkRs1Mj9B3wj3itrzMa38D4_XGryOIFks/edit?usp=sharing Thanks Saurabh & Abhi