Hi,
I don’t think it’s possible “out-of-the-box” now but it could be a useful
add-on for JdbcIO connector (dead-letter pcollection) since, iirc, it was
already asked several times by users. For the moment, it’s only possible to
play with RetryStrategy/RetryConfiguration in case of failures.
—
Hi all,
I am trying to figure out the right approach to handling failed records
when persisting to a database through the JdbcIO sink. We have created a
DoFn to do this task through a PreparedStatement and catch any exceptions
then send it through side output for further processing if required.