autoformatting

snowflakedb · Oct 25, 2023 · c879084 · c879084
1 parent b57b68b
commit c879084
Showing 1 changed file with 1 addition and 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
@@ -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:{}",