diff --git a/integration-tests/multioutput/src/test/java/io/quarkiverse/kafkastreamsprocessor/sample/multioutput/PingProcessorIT.java b/integration-tests/multioutput/src/test/java/io/quarkiverse/kafkastreamsprocessor/sample/multioutput/PingProcessorIT.java
index e7dedd2..d7fbb4c 100644
--- a/integration-tests/multioutput/src/test/java/io/quarkiverse/kafkastreamsprocessor/sample/multioutput/PingProcessorIT.java
+++ b/integration-tests/multioutput/src/test/java/io/quarkiverse/kafkastreamsprocessor/sample/multioutput/PingProcessorIT.java
@@ -20,7 +20,16 @@
package io.quarkiverse.kafkastreamsprocessor.sample.multioutput;
import io.quarkus.test.junit.QuarkusIntegrationTest;
+import io.quarkus.test.junit.QuarkusTestProfile;
+import io.quarkus.test.junit.TestProfile;
@QuarkusIntegrationTest
+@TestProfile(PingProcessorIT.TestProfile.class)
public class PingProcessorIT extends PingProcessorQuarkusTest {
+ public static class TestProfile implements QuarkusTestProfile {
+ @Override
+ public String getConfigProfile() {
+ return "test";
+ }
+ }
}
diff --git a/integration-tests/simple/src/test/java/io/quarkiverse/kafkastreamsprocessor/sample/simple/PingProcessorIT.java b/integration-tests/simple/src/test/java/io/quarkiverse/kafkastreamsprocessor/sample/simple/PingProcessorIT.java
index 00c0e1a..de82f09 100644
--- a/integration-tests/simple/src/test/java/io/quarkiverse/kafkastreamsprocessor/sample/simple/PingProcessorIT.java
+++ b/integration-tests/simple/src/test/java/io/quarkiverse/kafkastreamsprocessor/sample/simple/PingProcessorIT.java
@@ -20,8 +20,16 @@
package io.quarkiverse.kafkastreamsprocessor.sample.simple;
import io.quarkus.test.junit.QuarkusIntegrationTest;
+import io.quarkus.test.junit.QuarkusTestProfile;
+import io.quarkus.test.junit.TestProfile;
@QuarkusIntegrationTest
+@TestProfile(PingProcessorIT.TestProfile.class)
public class PingProcessorIT extends PingProcessorQuarkusTest {
-
+ public static class TestProfile implements QuarkusTestProfile {
+ @Override
+ public String getConfigProfile() {
+ return "test";
+ }
+ }
}
diff --git a/integration-tests/stateful/src/test/java/io/quarkiverse/kafkastreamsprocessor/sample/stateful/PingProcessorIT.java b/integration-tests/stateful/src/test/java/io/quarkiverse/kafkastreamsprocessor/sample/stateful/PingProcessorIT.java
index e2cc8ce..f8eacdc 100644
--- a/integration-tests/stateful/src/test/java/io/quarkiverse/kafkastreamsprocessor/sample/stateful/PingProcessorIT.java
+++ b/integration-tests/stateful/src/test/java/io/quarkiverse/kafkastreamsprocessor/sample/stateful/PingProcessorIT.java
@@ -20,7 +20,16 @@
package io.quarkiverse.kafkastreamsprocessor.sample.stateful;
import io.quarkus.test.junit.QuarkusIntegrationTest;
+import io.quarkus.test.junit.QuarkusTestProfile;
+import io.quarkus.test.junit.TestProfile;
@QuarkusIntegrationTest
+@TestProfile(PingProcessorIT.TestProfile.class)
public class PingProcessorIT extends PingProcessorQuarkusTest {
+ public static class TestProfile implements QuarkusTestProfile {
+ @Override
+ public String getConfigProfile() {
+ return "test";
+ }
+ }
}
diff --git a/pom.xml b/pom.xml
index db00dac..76ca30e 100644
--- a/pom.xml
+++ b/pom.xml
@@ -4,7 +4,7 @@
io.quarkiverse
quarkiverse-parent
- 18
+ 20
io.quarkiverse.kafkastreamsprocessor
quarkus-kafka-streams-processor-parent
@@ -28,12 +28,12 @@
HEAD
- 3.13.0
+ 3.14.0
17
UTF-8
UTF-8
- 3.15.3
+ 3.20.0
3.25.5
diff --git a/test-framework/src/main/java/io/quarkiverse/kafkastreamsprocessor/testframework/StateDirCleaningResource.java b/test-framework/src/main/java/io/quarkiverse/kafkastreamsprocessor/testframework/StateDirCleaningResource.java
index 80934d6..6857a10 100644
--- a/test-framework/src/main/java/io/quarkiverse/kafkastreamsprocessor/testframework/StateDirCleaningResource.java
+++ b/test-framework/src/main/java/io/quarkiverse/kafkastreamsprocessor/testframework/StateDirCleaningResource.java
@@ -50,7 +50,7 @@ public Map start() {
@Override
public void stop() {
try {
- FileUtils.forceDelete(tmpDir);
+ FileUtils.forceDeleteOnExit(tmpDir);
} catch (Exception e) {
throw new RuntimeException("error deleting " + tmpDir, e);
}
diff --git a/test-framework/src/test/java/io/quarkiverse.kafkastreamsprocessor.testframework/StateDirCleaningResourceTest.java b/test-framework/src/test/java/io/quarkiverse.kafkastreamsprocessor.testframework/StateDirCleaningResourceTest.java
index 2b3fc5e..7d61f18 100644
--- a/test-framework/src/test/java/io/quarkiverse.kafkastreamsprocessor.testframework/StateDirCleaningResourceTest.java
+++ b/test-framework/src/test/java/io/quarkiverse.kafkastreamsprocessor.testframework/StateDirCleaningResourceTest.java
@@ -23,9 +23,7 @@
import static org.hamcrest.Matchers.containsString;
import static org.hamcrest.Matchers.equalTo;
import static org.hamcrest.Matchers.hasEntry;
-import static org.junit.jupiter.api.Assertions.assertFalse;
-import java.io.File;
import java.util.Map;
import org.junit.jupiter.api.Test;
@@ -40,8 +38,6 @@ void createsTempDirAndDeletesIt() {
assertThat(props, hasEntry(equalTo("kafka-streams.state.dir"), containsString("kstreamstateful")));
resource.stop();
-
- assertFalse(new File(props.get("kafka-streams.state.dir")).exists());
}
}