MartijnVisser commented on PR #15487: URL: https://github.com/apache/flink/pull/15487#issuecomment-1092117547
@sazzad16 We're currently in the process of externalizing connectors from Flink's main repository to their own individual repositories. For example, the Elasticsearch connector is being moved from this repo to https://github.com/apache/flink-connector-elasticsearch. While working on moving out Elasticsearch, we're also creating some templates/examples/archetype for all other connectors. The idea would be that we create a new repo for Redis, flink-connector-redis. You could open up PRs against that repo. A Source should be build via the Source API (see FLIP-27 https://cwiki.apache.org/confluence/display/FLINK/FLIP-27%3A+Refactor+Source+Interface) and Sinks using the Unified Sink API / ASync API (see FLIP-143 https://cwiki.apache.org/confluence/display/FLINK/FLIP-143%3A+Unified+Sink+API and FLIP-171 https://cwiki.apache.org/confluence/display/FLINK/FLIP-171%3A+Async+Sink). This also depends on the level of guarantees (at least once, at most once, exactly once etc) you want to guarantee. There are maintainers in the Flink community who can help with reviews for these type of implementations. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
