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

---
 .../java/de/juplo/kafka/chat/backend/KafkaConfigurationIT.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 f25feb69..f6a3607e 100644
--- 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
-- 
2.20.1