From d292bb847907f4c00222f7432b28c6979944fc88 Mon Sep 17 00:00:00 2001
From: Chris Cranford <chris@hibernate.org>
Date: Mon, 8 Jul 2024 11:40:25 -0400
Subject: [PATCH] DBZ-7946 Add log message during partition open requests

---
 .../debezium/connector/jdbc/JdbcSinkConnectorTask.java   | 9 +++++++++
 1 file changed, 9 insertions(+)

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) {