This PR introduces the ability of the producer to reload its underlying client when in transactional mode. This allows us to deal with cases when something goes wrong and a given instance should not be used.
Since it is used only from inside locked transactions, this does not have race conditions.
Fencing is excluded to prevent some weird race conditions.
This PR introduces the ability of the producer to reload its underlying client when in transactional mode. This allows us to deal with cases when something goes wrong and a given instance should not be used.
Since it is used only from inside locked transactions, this does not have race conditions.
Fencing is excluded to prevent some weird race conditions.
close https://github.com/karafka/waterdrop/issues/501