From 8ad452d60f899164b51ab8730e6d2976c8022fad Mon Sep 17 00:00:00 2001
From: Gunnar Morling <gunnar.morling@googlemail.com>
Date: Fri, 13 Jul 2018 12:38:52 +0200
Subject: [PATCH] DBZ-720 Avoiding race condition where we tried to commit an
 offset to an already closed xout server

---
 .../connector/oracle/OracleStreamingChangeEventSource.java    | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/OracleStreamingChangeEventSource.java b/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/OracleStreamingChangeEventSource.java
index ccb5b77ac..545262e6e 100644
--- a/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/OracleStreamingChangeEventSource.java
+++ b/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/OracleStreamingChangeEventSource.java
@@ -71,8 +71,10 @@ public void execute(ChangeEventSourceContext context) throws InterruptedExceptio
         }
         finally {
             // 3. disconnect
-            if (xsOut != null) {
+            if (this.xsOut != null) {
                 try {
+                    XStreamOut xsOut = this.xsOut;
+                    this.xsOut = null;
                     xsOut.detach(XStreamOut.DEFAULT_MODE);
                 }
                 catch (StreamsException e) {