diff --git a/kafka-client/src/main/java/dev/responsive/kafka/internal/config/ResponsiveStreamsConfig.java b/kafka-client/src/main/java/dev/responsive/kafka/internal/config/ResponsiveStreamsConfig.java
index d25b4998..fad347d9 100644
--- a/kafka-client/src/main/java/dev/responsive/kafka/internal/config/ResponsiveStreamsConfig.java
+++ b/kafka-client/src/main/java/dev/responsive/kafka/internal/config/ResponsiveStreamsConfig.java
@@ -20,7 +20,6 @@
 import java.util.Map;
 import org.apache.kafka.common.config.ConfigException;
 import org.apache.kafka.streams.StreamsConfig;
-import org.apache.kafka.streams.state.DslStoreSuppliers;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
diff --git a/kafka-client/src/test/java/dev/responsive/kafka/api/ResponsiveKafkaStreamsTest.java b/kafka-client/src/test/java/dev/responsive/kafka/api/ResponsiveKafkaStreamsTest.java
index 78fdb3f6..85218275 100644
--- a/kafka-client/src/test/java/dev/responsive/kafka/api/ResponsiveKafkaStreamsTest.java
+++ b/kafka-client/src/test/java/dev/responsive/kafka/api/ResponsiveKafkaStreamsTest.java
@@ -58,7 +58,6 @@
 import org.apache.kafka.common.serialization.Serdes;
 import org.apache.kafka.streams.KafkaClientSupplier;
 import org.apache.kafka.streams.StreamsBuilder;
-import org.apache.kafka.streams.errors.StreamsException;
 import org.apache.kafka.streams.processor.internals.DefaultKafkaClientSupplier;
 import org.hamcrest.Matchers;
 import org.junit.jupiter.api.BeforeEach;
diff --git a/kafka-client/src/test/java/dev/responsive/kafka/testutils/SimpleStatefulProcessorSupplier.java b/kafka-client/src/test/java/dev/responsive/kafka/testutils/SimpleStatefulProcessorSupplier.java
index f4026d5d..4ce26230 100644
--- a/kafka-client/src/test/java/dev/responsive/kafka/testutils/SimpleStatefulProcessorSupplier.java
+++ b/kafka-client/src/test/java/dev/responsive/kafka/testutils/SimpleStatefulProcessorSupplier.java
@@ -12,7 +12,6 @@
 
 package dev.responsive.kafka.testutils;
 
-import dev.responsive.kafka.api.stores.ResponsiveKeyValueParams;
 import dev.responsive.kafka.api.stores.ResponsiveStores;
 import dev.responsive.kafka.testutils.SimpleStatefulProcessor.ComputeStatefulOutput;
 import java.util.Collections;