diff --git a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleBlobDataTypesIT.java b/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleBlobDataTypesIT.java
index bbca091d4..07e3bbaaa 100644
--- a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleBlobDataTypesIT.java
+++ b/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleBlobDataTypesIT.java
@@ -1124,7 +1124,7 @@ record = table.get(1);
             // Get streaming records
             sourceRecords = consumeRecordsByTopic(logMinerAdapter ? 3 : 2);
             table = sourceRecords.recordsForTopic(topicName("DBZ3645"));
-            assertThat(table).hasSize(3);
+            assertThat(table).hasSize(logMinerAdapter ? 3 : 2);
 
             record = table.get(0);
             after = ((Struct) record.value()).getStruct(Envelope.FieldName.AFTER);
diff --git a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleClobDataTypeIT.java b/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleClobDataTypeIT.java
index cbe525a74..85278b10c 100644
--- a/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleClobDataTypeIT.java
+++ b/debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/OracleClobDataTypeIT.java
@@ -1508,7 +1508,7 @@ record = table.get(1);
             // Get streaming records
             sourceRecords = consumeRecordsByTopic(logMinerAdapter ? 3 : 2);
             table = sourceRecords.recordsForTopic(topicName("DBZ3645"));
-            assertThat(table).hasSize(3);
+            assertThat(table).hasSize(logMinerAdapter ? 3 : 2);
 
             record = table.get(0);
             after = ((Struct) record.value()).getStruct(Envelope.FieldName.AFTER);