checkstyle

responsivedev · Nov 22, 2023 · a883999 · a883999
1 parent 5c15ca0
commit a883999
Show file tree

Hide file tree

Showing 5 changed files with 5 additions and 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
@@ -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/...lient/src/main/java/dev/responsive/kafka/internal/db/partitioning/SegmentPartitioner.java b/...lient/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
@@ -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/.../src/test/java/dev/responsive/kafka/integration/ResponsiveWindowStoreIntegrationTest.java b/.../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
@@ -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;