WIP

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 f25feb6..f6a3607 100644 (file)
--- a/src/test/java/de/juplo/kafka/chat/backend/KafkaConfigurationIT.java
+++ b/src/test/java/de/juplo/kafka/chat/backend/KafkaConfigurationIT.java
@@ -53,6 +53,7 @@ class KafkaConfigurationIT extends AbstractConfigurationWithShardingIT
   {
     List<TopicPartition> assignedPartitions = List.of(new TopicPartition(TOPIC, 2));
     chatRoomChannelConsumer.assign(assignedPartitions);
+    chatRoomChannel.onPartitionsAssigned(assignedPartitions);
     CONSUMER_JOB = taskExecutor
         .submitCompletable(chatRoomChannel)
         .exceptionally(e ->
@@ -60,7 +61,6 @@ class KafkaConfigurationIT extends AbstractConfigurationWithShardingIT
           log.error("The consumer for the ChatRoomChannel exited abnormally!", e);
           return null;
         });
-    chatRoomChannel.onPartitionsAssigned(assignedPartitions);
   }
 
   @BeforeAll