Uploaded image for project: 'Debezium'
  1. Debezium
  2. DBZ-2124

Don't call markBatchFinished() in finally block

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Done
    • Icon: Major Major
    • 1.2.0.CR1
    • None
    • embedded-engine
    • None

      See io.debezium.embedded.EmbeddedEngine.buildDefaultChangeConsumer(Consumer<SourceRecord>). markBatchFinished() must not be called in case of an exception.

            ccranfor@redhat.com Chris Cranford
            gunnar.morling Gunnar Morling
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

              Created:
              Updated:
              Resolved: