diff --git a/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/processor/AbstractLogMinerEventProcessor.java b/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/processor/AbstractLogMinerEventProcessor.java
index 67d16fb49..c3c1526ae 100644
--- a/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/processor/AbstractLogMinerEventProcessor.java
+++ b/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/processor/AbstractLogMinerEventProcessor.java
@@ -1427,7 +1427,7 @@ public void abandonTransactions(Duration retention) throws InterruptedException
                                 if (first) {
                                     LOGGER.warn("All transactions with SCN <= {} will be abandoned.", thresholdScn);
                                     if (LOGGER.isDebugEnabled()) {
-                                        try (Stream s = getTransactionCache().keySet().stream()) {
+                                        try (Stream<String> s = getTransactionCache().keySet().stream()) {
                                             LOGGER.debug("List of transactions in the cache before transactions being abandoned: [{}]",
                                                     s.collect(Collectors.joining(",")));
                                         }
@@ -1452,7 +1452,7 @@ public void abandonTransactions(Duration retention) throws InterruptedException
                         }
                     }
                     if (LOGGER.isDebugEnabled()) {
-                        try (Stream s = getTransactionCache().keySet().stream()) {
+                        try (Stream<String> s = getTransactionCache().keySet().stream()) {
                             LOGGER.debug("List of transactions in the cache after transactions being abandoned: [{}]",
                                     s.collect(Collectors.joining(",")));
                         }