From d3a098c82ddff66aace9a64826c1758d973d9afe Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Fri, 15 Sep 2023 14:16:23 +0200 Subject: [PATCH] VORTASTEN --- .../juplo/kafka/chat/backend/KafkaConfigurationIT.java | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) diff --git a/src/test/java/de/juplo/kafka/chat/backend/KafkaConfigurationIT.java b/src/test/java/de/juplo/kafka/chat/backend/KafkaConfigurationIT.java index 0cd5edc4..d9ed8eb0 100644 --- a/src/test/java/de/juplo/kafka/chat/backend/KafkaConfigurationIT.java +++ b/src/test/java/de/juplo/kafka/chat/backend/KafkaConfigurationIT.java @@ -6,6 +6,7 @@ import org.junit.jupiter.api.AfterAll; import org.junit.jupiter.api.BeforeAll; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.test.context.SpringBootTest; +import org.springframework.boot.test.context.TestConfiguration; import org.springframework.boot.test.mock.mockito.MockBean; import org.springframework.context.annotation.Import; import org.springframework.kafka.core.KafkaTemplate; @@ -27,7 +28,6 @@ import static de.juplo.kafka.chat.backend.KafkaConfigurationIT.INFO_TOPIC; "chat.backend.kafka.data-channel-topic=" + DATA_TOPIC, "chat.backend.kafka.num-partitions=10", }) -@Import(KafkaTestUtils.KafkaTestConfiguration.class) @EmbeddedKafka( topics = { INFO_TOPIC, DATA_TOPIC }, partitions = 10) @@ -57,4 +57,11 @@ class KafkaConfigurationIT extends AbstractConfigurationWithShardingIT { KafkaTestUtils.joinConsumerTasks(consumerTaskRunner); } + + + @TestConfiguration + @Import(KafkaTestUtils.KafkaTestConfiguration.class) + static class KafkaConfigurationITConfiguration + { + } } -- 2.20.1