Re: Sink to database with multiple statements in a transaction, and with retry

2023-01-05 Thread Yoni Gibbs
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

Sink to database with multiple statements in a transaction, and with retry

2023-01-05 Thread Yoni Gibbs
I want to sink some data to a database, but the data needs to go into multiple tables, in a single transaction. Am I right in saying that I cannot use the JDBC Connector for this as it only handles single SQL statements? Assuming that's right, I believe that I need to write a custom sink, so I n