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 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 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.