From b0c4cc86ba5d7594435fe6b67eab99e043b2e5f8 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Sun, 20 Aug 2023 10:35:35 +0200
Subject: [PATCH] WIP

---
 .../de/juplo/kafka/chat/backend/KafkaConfigurationIT.java  | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

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 e343174d..d1427602 100644
--- a/src/test/java/de/juplo/kafka/chat/backend/KafkaConfigurationIT.java
+++ b/src/test/java/de/juplo/kafka/chat/backend/KafkaConfigurationIT.java
@@ -20,12 +20,13 @@ import static de.juplo.kafka.chat.backend.KafkaConfigurationIT.TOPIC;
         "chat.backend.kafka.client-id-PREFIX=TEST",
         "chat.backend.kafka.bootstrap-servers=${spring.embedded.kafka.brokers}",
         "spring.kafka.bootstrap-servers=${spring.embedded.kafka.brokers}",
-        "chat.backend.kafka.message-channel-topic=" + TOPIC,
-        "chat.backend.kafka.num-partitions=10" })
+        "chat.backend.kafka.chatroom-channel-topic=" + TOPIC,
+        "chat.backend.kafka.num-partitions=10",
+        })
 @EmbeddedKafka(topics = { TOPIC }, partitions = 10)
 class KafkaConfigurationIT extends AbstractConfigurationWithShardingIT
 {
-  final static String TOPIC = "TEST_MESSAGE_CHANNEL";
+  final static String TOPIC = "TEST_CHATROOM_CHANNEL";
 
   @BeforeAll
   public static void test(
-- 
2.20.1