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 b5bc301..f12775a 100644 (file)
--- 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 4b19897..5272729 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
@@ -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)