VORTASTEN

diff --git a/src/test/java/de/juplo/kafka/chat/backend/implementation/kafka/KafkaTestUtils.java b/src/test/java/de/juplo/kafka/chat/backend/implementation/kafka/KafkaTestUtils.java
index a00f2c1..4fc7aa1 100644 (file)
--- a/src/test/java/de/juplo/kafka/chat/backend/implementation/kafka/KafkaTestUtils.java
+++ b/src/test/java/de/juplo/kafka/chat/backend/implementation/kafka/KafkaTestUtils.java
@@ -10,6 +10,7 @@ import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Import;
 import org.springframework.kafka.core.KafkaTemplate;
 import org.springframework.kafka.support.SendResult;
+import org.springframework.test.context.TestPropertySource;
 
 import java.time.Clock;
 import java.util.List;
@@ -24,7 +25,14 @@ public class KafkaTestUtils
   @TestConfiguration
   @EnableConfigurationProperties(ChatBackendProperties.class)
   @Import(KafkaServicesConfiguration.class)
-  static class KafkaTestConfiguration
+  @TestPropertySource(properties = {
+      "spring.main.allow-bean-definition-overriding=true",
+      "chat.backend.services=kafka",
+      "chat.backend.kafka.client-id-PREFIX=TEST",
+      "chat.backend.kafka.bootstrap-servers=${spring.embedded.kafka.brokers}",
+      "spring.kafka.bootstrap-servers=${spring.embedded.kafka.brokers}",
+  })
+  public static class KafkaTestConfiguration
   {
     @Bean
     WorkAssignor dataChannelWorkAssignor(DataChannel dataChannel)