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

Execution of RecordsStreamProducer.closeConnections() is susceptible to race condition

XMLWordPrintable

      The closeConnections() method is called if and only if the method start() was executed successfully setting replicationStream. The problem is that the method closes also replicationConnection that is created in the constructor. The ent result is that the resources might not be cleaned if the startup sequence has not been completed. This can be issue especially with cluster rebalancing.

              jpechane Jiri Pechanec
              jpechane Jiri Pechanec
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

                Created:
                Updated:
                Resolved: