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?

Reply via email to