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()); } }