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

Don't call markBatchFinished() in finally block

    XMLWordPrintable

Details

    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
            gmorling@redhat.com Gunnar Morling
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: