Also, it seems that sinks have to be synchronous, I think? (Unless there's some async equivalent of SinkFunction?) Assuming they're synchronous, if I do the retry strategy manually in the implementation of SinkFunction.invoke that means I'll be blocking that thread while waiting to do a retry (e.g. with some back-off strategy), I believe. Is that correct?
- Sink to database with multiple statements in a transaction, and... Yoni Gibbs
- Re: Sink to database with multiple statements in a transac... Yoni Gibbs