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

Don't call markBatchFinished() in finally block

    XMLWordPrintable

Details

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

    Description

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

      Attachments

        Activity

          People

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

            Dates

              Created:
              Updated:
              Resolved: