Prasanna,
The Flink project does not have an SQS connector, and a quick google search
hasn't found one. Nor does Flink have an HTTP sink, but with a bit of
googling you can find that various folks have implemented this themselves.
As for implementing SQS as a custom sink, if you need exactly once
Hi ,
I did not find out of box flink sink connector for http and SQS mechanism.
Has anyone implemented it?
Wanted to know if we are writing a custom sink function , whether it
would affect semantic exactly one guarantees ?
Thanks ,
Prasanna
Jingsong Lee created FLINK-13349:
Summary: Flink sinks should implement consumeDataStream instead of
emitDataStream
Key: FLINK-13349
URL: https://issues.apache.org/jira/browse/FLINK-13349
Project
