From: Kai Moritz Date: Fri, 15 Sep 2023 09:39:39 +0000 (+0200) Subject: WIP:ALIGN X-Git-Tag: rebase--2023-09-15--16-33~18 X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=db35a7bbddaafacf08afd3ca5c2ba0c697caae79;p=demos%2Fkafka%2Fchat WIP:ALIGN --- diff --git a/src/test/java/de/juplo/kafka/chat/backend/implementation/kafka/KafkaChatHomeServiceTest.java b/src/test/java/de/juplo/kafka/chat/backend/implementation/kafka/KafkaChatHomeServiceTest.java index 129ab2b3..b5bc301b 100644 --- a/src/test/java/de/juplo/kafka/chat/backend/implementation/kafka/KafkaChatHomeServiceTest.java +++ b/src/test/java/de/juplo/kafka/chat/backend/implementation/kafka/KafkaChatHomeServiceTest.java @@ -8,6 +8,7 @@ import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.autoconfigure.kafka.KafkaAutoConfiguration; import org.springframework.boot.autoconfigure.task.TaskExecutionAutoConfiguration; import org.springframework.boot.test.context.SpringBootTest; +import org.springframework.context.annotation.Import; import org.springframework.kafka.core.KafkaTemplate; import org.springframework.kafka.test.context.EmbeddedKafka; @@ -18,7 +19,6 @@ import static de.juplo.kafka.chat.backend.implementation.kafka.KafkaChatHomeServ @SpringBootTest( classes = { - KafkaTestConfiguration.class, KafkaAutoConfiguration.class, TaskExecutionAutoConfiguration.class, }, @@ -27,6 +27,7 @@ import static de.juplo.kafka.chat.backend.implementation.kafka.KafkaChatHomeServ "chat.backend.kafka.data-channel-topic=" + DATA_TOPIC, "chat.backend.kafka.num-partitions=" + NUM_SHARDS, }) +@Import(KafkaTestConfiguration.class) @EmbeddedKafka( topics = { INFO_TOPIC, DATA_TOPIC }, partitions = 10)