Details
-
Bug
-
Resolution: Done
-
Major
-
None
-
None
Description
See io.debezium.embedded.EmbeddedEngine.buildDefaultChangeConsumer(Consumer<SourceRecord>). markBatchFinished() must not be called in case of an exception.
See io.debezium.embedded.EmbeddedEngine.buildDefaultChangeConsumer(Consumer<SourceRecord>). markBatchFinished() must not be called in case of an exception.