diff --git a/COPYRIGHT.txt b/COPYRIGHT.txt
index f5bd52dde..405a895f3 100644
--- a/COPYRIGHT.txt
+++ b/COPYRIGHT.txt
@@ -139,6 +139,7 @@ Guy Korland
 Guy Pascarella
 Grzegorz Kołakowski
 Jacob Gminder
+Jan Doms
 Jan Hendrik Dolling
 Jason Schweier
 Jiabao Sun
diff --git a/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/LogMinerStreamingChangeEventSource.java b/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/LogMinerStreamingChangeEventSource.java
index 0f30df235..112b858f5 100644
--- a/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/LogMinerStreamingChangeEventSource.java
+++ b/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/LogMinerStreamingChangeEventSource.java
@@ -607,16 +607,16 @@ private Scn calculateEndScn(OracleConnection connection, Scn startScn, Scn prevE
         streamingMetrics.setCurrentScn(currentScn);
 
         // Add the current batch size to the starting system change number
-        Scn topScnToMine = startScn.add(Scn.valueOf(streamingMetrics.getBatchSize()));
+        final Scn currentBatchSizeScn = Scn.valueOf(streamingMetrics.getBatchSize());
+        Scn topScnToMine = startScn.add(currentBatchSizeScn);
 
         // Control adjusting batch size
         boolean topMiningScnInFarFuture = false;
-        final Scn defaultBatchScn = Scn.valueOf(connectorConfig.getLogMiningBatchSizeDefault());
-        if (topScnToMine.subtract(currentScn).compareTo(defaultBatchScn) > 0) {
+        if (topScnToMine.subtract(currentScn).compareTo(currentBatchSizeScn) > 0) {
             streamingMetrics.changeBatchSize(false, connectorConfig.isLobEnabled());
             topMiningScnInFarFuture = true;
         }
-        if (currentScn.subtract(topScnToMine).compareTo(defaultBatchScn) > 0) {
+        if (currentScn.subtract(topScnToMine).compareTo(currentBatchSizeScn) > 0) {
             streamingMetrics.changeBatchSize(true, connectorConfig.isLobEnabled());
         }