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 c0d01ac56..dfe72a654 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 @@ -516,8 +516,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); }); } @@ -537,8 +537,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.