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

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

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Done
    • Icon: Major 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.

      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

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

                Created:
                Updated:
                Resolved: