From: Kai Moritz <kai@juplo.de>
Date: Fri, 15 Sep 2023 09:45:40 +0000 (+0200)
Subject: WIP:ALIGN
X-Git-Tag: rebase--2023-09-15--16-33~17
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=167b1951b859125994427df7672b4416646fe70f;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 b5bc301b..f12775ab 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
@@ -27,7 +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)
+@Import(KafkaTestUtils.class)
 @EmbeddedKafka(
     topics = { INFO_TOPIC, DATA_TOPIC },
     partitions = 10)
@@ -42,7 +42,7 @@ public class KafkaChatHomeServiceTest extends ChatHomeServiceWithShardsTest
       @Autowired ConsumerTaskRunner consumerTaskRunner,
       @Autowired KafkaTemplate<String, String> messageTemplate)
   {
-    KafkaTestConfiguration.sendAndLoadStoredData(
+    KafkaTestUtils.sendAndLoadStoredData(
         consumerTaskRunner,
         messageTemplate);
   }
@@ -50,6 +50,6 @@ public class KafkaChatHomeServiceTest extends ChatHomeServiceWithShardsTest
   @AfterAll
   static void joinConsumerTasks(@Autowired ConsumerTaskRunner consumerTaskRunner)
   {
-    KafkaTestConfiguration.joinConsumerTasks(consumerTaskRunner);
+    KafkaTestUtils.joinConsumerTasks(consumerTaskRunner);
   }
 }
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 4b19897a..52727290 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
@@ -30,7 +30,7 @@ import static de.juplo.kafka.chat.backend.implementation.kafka.KafkaChatHomeServ
     "spring.kafka.bootstrap-servers=${spring.embedded.kafka.brokers}",
 })
 @Slf4j
-public abstract class KafkaTestConfiguration
+public abstract class KafkaTestUtils
 {
   @Bean
   WorkAssignor dataChannelWorkAssignor(DataChannel dataChannel)