Fix logging for closing partition channels - partition and topic misp…

…laced
snowflakedb · Oct 26, 2024 · 49dc481 · 49dc481
1 parent 1302e36
commit 49dc481
Showing 1 changed file with 4 additions and 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
@@ -516,8 +516,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);
         });
   }
@@ -537,8 +537,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.