diff --git a/kafka-client/src/test/java/dev/responsive/kafka/integration/MinimalIntegrationTest.java b/kafka-client/src/test/java/dev/responsive/kafka/integration/MinimalIntegrationTest.java
index ac5795370..198725929 100644
--- a/kafka-client/src/test/java/dev/responsive/kafka/integration/MinimalIntegrationTest.java
+++ b/kafka-client/src/test/java/dev/responsive/kafka/integration/MinimalIntegrationTest.java
@@ -57,6 +57,7 @@
 import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.TestInfo;
+import org.junit.jupiter.api.Timeout;
 import org.junit.jupiter.api.extension.RegisterExtension;
 
 /**
@@ -65,7 +66,8 @@
  * the development workflow, and therefore is disabled by default (to speed
  * up test time).
  */
-@Disabled
+//@Disabled
+@Timeout(10_000_000)
 public class MinimalIntegrationTest {
 
   @RegisterExtension
diff --git a/responsive-spring/src/test/java/dev/responsive/spring/KafkaStreamsApp.java b/responsive-spring/src/test/java/dev/responsive/spring/KafkaStreamsApp.java
index 6e74257e1..c4d37aad3 100644
--- a/responsive-spring/src/test/java/dev/responsive/spring/KafkaStreamsApp.java
+++ b/responsive-spring/src/test/java/dev/responsive/spring/KafkaStreamsApp.java
@@ -20,7 +20,6 @@
 import java.util.Map;
 import org.apache.kafka.clients.admin.AdminClientConfig;
 import org.apache.kafka.clients.admin.NewTopic;
-import org.apache.kafka.clients.admin.TopicDescription;
 import org.apache.kafka.clients.producer.ProducerConfig;
 import org.apache.kafka.common.TopicPartition;
 import org.apache.kafka.common.serialization.ByteArraySerializer;