From a883999ba7943afdf6f444d3aba612bd627085c4 Mon Sep 17 00:00:00 2001
From: "A. Sophie Blee-Goldman" <sophie@responsive.dev>
Date: Tue, 21 Nov 2023 22:51:32 -0800
Subject: [PATCH] checkstyle

---
 .../responsive/kafka/internal/db/LwtWriterFactory.java    | 6 ------
 .../internal/db/partitioning/SegmentPartitioner.java      | 2 +-
 .../java/dev/responsive/kafka/internal/utils/Stamped.java | 8 ++++----
 .../integration/ResponsiveWindowStoreIntegrationTest.java | 1 -
 .../kafka/internal/stores/CommitBufferTest.java           | 1 -
 5 files changed, 5 insertions(+), 13 deletions(-)

diff --git a/kafka-client/src/main/java/dev/responsive/kafka/internal/db/LwtWriterFactory.java b/kafka-client/src/main/java/dev/responsive/kafka/internal/db/LwtWriterFactory.java
index 781ea6b7c..40ce0a3de 100644
--- a/kafka-client/src/main/java/dev/responsive/kafka/internal/db/LwtWriterFactory.java
+++ b/kafka-client/src/main/java/dev/responsive/kafka/internal/db/LwtWriterFactory.java
@@ -21,15 +21,9 @@
 import com.datastax.oss.driver.api.core.cql.BoundStatement;
 import dev.responsive.kafka.internal.db.partitioning.TablePartitioner;
 import dev.responsive.kafka.internal.stores.RemoteWriteResult;
-import java.util.List;
-import org.apache.kafka.streams.errors.TaskMigratedException;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 
 public class LwtWriterFactory<K, P> extends WriterFactory<K, P> {
 
-  private static final Logger LOG = LoggerFactory.getLogger(LwtWriterFactory.class);
-
   private final RemoteTable<K, BoundStatement> table;
   private final TableMetadata<P> tableMetadata;
   private final CassandraClient client;
diff --git a/kafka-client/src/main/java/dev/responsive/kafka/internal/db/partitioning/SegmentPartitioner.java b/kafka-client/src/main/java/dev/responsive/kafka/internal/db/partitioning/SegmentPartitioner.java
index 226cb2e2f..53198a578 100644
--- a/kafka-client/src/main/java/dev/responsive/kafka/internal/db/partitioning/SegmentPartitioner.java
+++ b/kafka-client/src/main/java/dev/responsive/kafka/internal/db/partitioning/SegmentPartitioner.java
@@ -136,7 +136,7 @@ public SegmentPartitioner(
                 retentionPeriodMs, segmentIntervalMs, windowSizeMs);
       throw new IllegalStateException("Segment partitioner received a negative or zero value");
     }
-    
+
     LOG.info("Created segment partitioner with retentionPeriod={}ms, segmentInterval={}ms,"
                  + " and windowSize={}ms", retentionPeriodMs, segmentIntervalMs, windowSizeMs);
   }
diff --git a/kafka-client/src/main/java/dev/responsive/kafka/internal/utils/Stamped.java b/kafka-client/src/main/java/dev/responsive/kafka/internal/utils/Stamped.java
index 346e92c2a..2cedc2bd2 100644
--- a/kafka-client/src/main/java/dev/responsive/kafka/internal/utils/Stamped.java
+++ b/kafka-client/src/main/java/dev/responsive/kafka/internal/utils/Stamped.java
@@ -28,9 +28,9 @@ public Stamped(final K key, final long stamp) {
 
   @Override
   public String toString() {
-    return "Stamped{" +
-        "key=" + key +
-        ", windowStart=" + stamp +
-        '}';
+    return "Stamped{"
+        + "key=" + key
+        + ", windowStart=" + stamp
+        + '}';
   }
 }
diff --git a/kafka-client/src/test/java/dev/responsive/kafka/integration/ResponsiveWindowStoreIntegrationTest.java b/kafka-client/src/test/java/dev/responsive/kafka/integration/ResponsiveWindowStoreIntegrationTest.java
index 479bc7b55..6cfb5339e 100644
--- a/kafka-client/src/test/java/dev/responsive/kafka/integration/ResponsiveWindowStoreIntegrationTest.java
+++ b/kafka-client/src/test/java/dev/responsive/kafka/integration/ResponsiveWindowStoreIntegrationTest.java
@@ -52,7 +52,6 @@
 import java.util.concurrent.CountDownLatch;
 import java.util.concurrent.ExecutionException;
 import java.util.concurrent.TimeUnit;
-import java.util.concurrent.atomic.AtomicInteger;
 import java.util.concurrent.atomic.AtomicLong;
 import java.util.function.Supplier;
 import org.apache.kafka.clients.admin.Admin;
diff --git a/kafka-client/src/test/java/dev/responsive/kafka/internal/stores/CommitBufferTest.java b/kafka-client/src/test/java/dev/responsive/kafka/internal/stores/CommitBufferTest.java
index 99bce7d28..eda9ecced 100644
--- a/kafka-client/src/test/java/dev/responsive/kafka/internal/stores/CommitBufferTest.java
+++ b/kafka-client/src/test/java/dev/responsive/kafka/internal/stores/CommitBufferTest.java
@@ -55,7 +55,6 @@
 import dev.responsive.kafka.internal.db.CassandraClient;
 import dev.responsive.kafka.internal.db.CassandraKeyValueTable;
 import dev.responsive.kafka.internal.db.KeySpec;
-import dev.responsive.kafka.internal.db.LwtWriterFactory;
 import dev.responsive.kafka.internal.db.partitioning.SubPartitioner;
 import dev.responsive.kafka.internal.db.spec.BaseTableSpec;
 import dev.responsive.kafka.internal.metrics.ClientVersionMetadata;