DBZ-7946 Add log message during partition open requests

debezium · Jul 10, 2024 · f332a76 · f332a76
1 parent 78f379b
commit f332a76
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/src/main/java/io/debezium/connector/jdbc/JdbcSinkConnectorTask.java b/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) {