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

EmbeddedEngine passes time of last commit to policy, not time since

    Details

    • Type: Bug
    • Status: Closed (View Workflow)
    • Priority: Major
    • Resolution: Done
    • Affects Version/s: 0.7.3, 0.7.4
    • Fix Version/s: 0.7.5
    • Component/s: embedded-engine
    • Labels:
      None
    • Environment:

      Any/all

    • Steps to Reproduce:
      Hide

      Run the debezium EmbeddedEngine with default `offset.commit.policy` (PeriodicCommitOffsetPolicy) and `offset.flush.interval.ms` (60000) configuration and note that offsets are flushed to offset backing store on every changeset instead of at the configured interval.

      Show
      Run the debezium EmbeddedEngine with default `offset.commit.policy` (PeriodicCommitOffsetPolicy) and `offset.flush.interval.ms` (60000) configuration and note that offsets are flushed to offset backing store on every changeset instead of at the configured interval.

      Description

      EmbeddedEngine records the time of last commit after offsets are committed to OffsetStorageWriter here:

      https://github.com/debezium/debezium/blob/master/debezium-embedded/src/main/java/io/debezium/embedded/EmbeddedEngine.java#L834

      Note that the variable is called `timeSinceLastCommit`, but actually contains the number of millis since the epoch.

      PR provided here: https://github.com/debezium/debezium/pull/489

        Gliffy Diagrams

          Attachments

            Activity

              People

              • Assignee:
                Unassigned
                Reporter:
                pattyocaml Andrew Tongen
              • Votes:
                0 Vote for this issue
                Watchers:
                2 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: