formatting

snowflakedb · Dec 7, 2023 · 5163e11 · 5163e11
1 parent b5fec68
commit 5163e11
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 6 deletions.
diff --git a/...main/java/com/snowflake/kafka/connector/internal/streaming/StreamingClientProperties.java b/...main/java/com/snowflake/kafka/connector/internal/streaming/StreamingClientProperties.java
@@ -45,11 +45,7 @@ public class StreamingClientProperties {
 
   // contains converted config properties that are loggable (not PII data)
   public static final List<String> LOGGABLE_STREAMING_CONFIG_PROPERTIES =
-      Stream.of(
-              Constants.ACCOUNT_URL,
-              Constants.ROLE,
-              Constants.USER)
-          .collect(Collectors.toList());
+      Stream.of(Constants.ACCOUNT_URL, Constants.ROLE, Constants.USER).collect(Collectors.toList());
 
   public final Properties clientProperties;
   public final String clientName;

diff --git a/src/test/java/com/snowflake/kafka/connector/internal/streaming/SnowflakeSinkServiceV2IT.java b/src/test/java/com/snowflake/kafka/connector/internal/streaming/SnowflakeSinkServiceV2IT.java
@@ -1,7 +1,6 @@
 package com.snowflake.kafka.connector.internal.streaming;
 
 import static com.snowflake.kafka.connector.SnowflakeSinkConnectorConfig.SNOWPIPE_STREAMING_MAX_CLIENT_LAG;
-import static com.snowflake.kafka.connector.internal.streaming.SnowflakeSinkServiceV2.partitionChannelKey;
 import static com.snowflake.kafka.connector.internal.streaming.TopicPartitionChannel.NO_OFFSET_TOKEN_REGISTERED_IN_SNOWFLAKE;
 
 import com.snowflake.kafka.connector.SnowflakeSinkConnectorConfig;