diff --git a/debezium-connector-jdbc/src/main/java/io/debezium/connector/jdbc/JdbcSinkConnectorTask.java b/debezium-connector-jdbc/src/main/java/io/debezium/connector/jdbc/JdbcSinkConnectorTask.java
index e0928459f..8f7ad67df 100644
--- a/debezium-connector-jdbc/src/main/java/io/debezium/connector/jdbc/JdbcSinkConnectorTask.java
+++ b/debezium-connector-jdbc/src/main/java/io/debezium/connector/jdbc/JdbcSinkConnectorTask.java
@@ -122,6 +122,15 @@ public void put(Collection<SinkRecord> records) {
         LOGGER.trace("[PERF] Mark processed execution time {}", markProcessedStopWatch.durations());
     }
 
+    @Override
+    public void open(Collection<TopicPartition> partitions) {
+        if (LOGGER.isTraceEnabled()) {
+            for (TopicPartition partition : partitions) {
+                LOGGER.trace("Requested open TopicPartition request for '{}'", partition);
+            }
+        }
+    }
+
     @Override
     public void close(Collection<TopicPartition> partitions) {
         for (TopicPartition partition : partitions) {