From c8790843ecd00db338ed51308e902fb692dd9730 Mon Sep 17 00:00:00 2001 From: revi cheng Date: Wed, 25 Oct 2023 14:33:07 -0700 Subject: [PATCH] autoformatting --- .../connector/internal/streaming/TopicPartitionChannel.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/src/main/java/com/snowflake/kafka/connector/internal/streaming/TopicPartitionChannel.java b/src/main/java/com/snowflake/kafka/connector/internal/streaming/TopicPartitionChannel.java index 952a14492..cf15a9c85 100644 --- a/src/main/java/com/snowflake/kafka/connector/internal/streaming/TopicPartitionChannel.java +++ b/src/main/java/com/snowflake/kafka/connector/internal/streaming/TopicPartitionChannel.java @@ -295,8 +295,7 @@ public InsertValidationResponse insertRecord(SinkRecord kafkaSinkRecord) { return finalResponse; } - public boolean shouldInsertRecord( - SinkRecord kafkaSinkRecord, long currProcessedOffset) { + public boolean shouldInsertRecord(SinkRecord kafkaSinkRecord, long currProcessedOffset) { if (currProcessedOffset == NO_OFFSET_TOKEN_REGISTERED_IN_SNOWFLAKE) { LOGGER.debug( "Insert record because there is no currProcessedOffset for channel:{}",