Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

We aim at enabling users to ignore the `send(ProducerRecord)` errors by defining a new `commitTransaction` method. The new method clears the latest error errors produced by `send(ProducerRecord)` and transits the transaction back from the error state.  In order to keep it safe, the change is applied to transactions with no unflushed record. Therefore, the user must explicitly call `flush()` before calling the newly defined  `commitTransaction`. 

...