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

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

    XMLWordPrintable

    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
    • 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

        Attachments

          Activity

            People

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

              Dates

              Created:
              Updated:
              Resolved: