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

Extract a separate change event class to be re-used across connectors

    XMLWordPrintable

Details

    • Task
    • Resolution: Done
    • Major
    • 0.7.3
    • None
    • core-library
    • None

    Description

      The goal of this is to centralize the polling logic in a single class and also separate the queue writers (e.g. binlog reader) from the queue readers (the code polling from the queue and propagating the changes to the Kafka Connect framework. It will also allow us to implement handling of certain options in a single place.

      This will also allow us to get rid of the BlockingReader in the MySQL connector: if the snapshot reader is done, the polling loop will keep going, but the handling in ChangeEventQueue#poll() will avoid the high CPU load originally motivating the blocking reader, as it regular sleeps for a while.

      Attachments

        Activity

          People

            gunnar.morling Gunnar Morling
            gunnar.morling Gunnar Morling
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: