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 f25feb695b8d4b8756d4dd7e1414c6b95c20a5c1..f6a3607ec63d3a8b9d091603fc913f032d035f69 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