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

Use the timestamp when LCR event happen in database to assign the timestamp of the SourceRecord received

    XMLWordPrintable

Details

    • Feature Request
    • Resolution: Unresolved
    • Critical
    • None
    • 1.0.0.Beta2
    • core-library
    • None
    • 0
    • 0% 0%

    Description

      hi , in my case, I use the mysql connector and ExtractNewRecordState transform to extract the LCR and use JDBC connector to load the event message to other mysql server.

      Now I want to do some end-to-end latency estimation on JDBC sink side. I find the timestamp of the SinkRecord received from Kafka topic is the the current timestamp when the source connector proccess the event and not the exact timestamp when the LCR happened in source database, in other words, I need the timestamp the mysql bin-log recorded.

      So I expect the ExtractNewRecordState can provider some way I can replace the default timestamp with more exact event timestamp alternatively.

      Attachments

        Issue Links

          Activity

            People

              Unassigned Unassigned
              binli1988 Bin LI (Inactive)
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated: