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

Switch RecordsStreamProducer to use non-blocking stream call

    Details

      Description

      Flushing LSN from a separate thread seems to be unsafe as the org.postgresql.replication.PGReplicationStream is not thread safe.

      This issue will try to swtich to non-blocking read of message and updating of LSN inisde the same thread loop.

        Gliffy Diagrams

          Attachments

            Activity

              People

              • Assignee:
                jpechanec Jiri Pechanec
                Reporter:
                jpechanec Jiri Pechanec
              • Votes:
                0 Vote for this issue
                Watchers:
                1 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: