From ad49fe6e5c81228911f17296e64f4047dcca6928 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Artur=20Chy=C5=BCy?= <artur.chyzy@snowflake.com>
Date: Mon, 28 Oct 2024 12:00:11 +0100
Subject: [PATCH] Fix logging for closing partition channels - partition and
 topic misplaced (#977)

---
 .../internal/streaming/SnowflakeSinkServiceV2.java        | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/src/main/java/com/snowflake/kafka/connector/internal/streaming/SnowflakeSinkServiceV2.java b/src/main/java/com/snowflake/kafka/connector/internal/streaming/SnowflakeSinkServiceV2.java
index 171a9a34c..7904eda67 100644
--- a/src/main/java/com/snowflake/kafka/connector/internal/streaming/SnowflakeSinkServiceV2.java
+++ b/src/main/java/com/snowflake/kafka/connector/internal/streaming/SnowflakeSinkServiceV2.java
@@ -518,8 +518,8 @@ private void closeSequentially(Collection<TopicPartition> partitions) {
           LOGGER.info(
               "Closing partitionChannel:{}, partition:{}, topic:{}",
               topicPartitionChannel == null ? null : topicPartitionChannel.getChannelNameFormatV1(),
-              topicPartition.topic(),
-              topicPartition.partition());
+              topicPartition.partition(),
+              topicPartition.topic());
           partitionsToChannel.remove(partitionChannelKey);
         });
   }
@@ -539,8 +539,8 @@ private CompletableFuture<Void> closeTopicPartition(TopicPartition topicPartitio
     LOGGER.info(
         "Closing partitionChannel:{}, partition:{}, topic:{}",
         topicPartitionChannel == null ? null : topicPartitionChannel.getChannelNameFormatV1(),
-        topicPartition.topic(),
-        topicPartition.partition());
+        topicPartition.partition(),
+        topicPartition.topic());
 
     // It's possible that some partitions can be unassigned before their respective channels are
     // even created.