From 28c2091c9b4c6f819b26a879584e39406887046c Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Fri, 15 Sep 2023 12:59:25 +0200
Subject: [PATCH] VORTASTEN

---
 .../backend/implementation/kafka/KafkaTestUtils.java   | 10 +++++++++-
 1 file changed, 9 insertions(+), 1 deletion(-)

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 a00f2c1f..4fc7aa10 100644
--- 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)
-- 
2.20.1