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

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

    XMLWordPrintable

Details

    • Bug
    • Resolution: Done
    • Major
    • 0.7.5
    • 0.7.3, 0.7.4
    • embedded-engine
    • None
    • 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

            Unassigned Unassigned
            atongen@gmail.com Andrew Tongen (Inactive)
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: