From: Kai Moritz <kai@juplo.de>
Date: Sun, 20 Aug 2023 09:14:37 +0000 (+0200)
Subject: WIP
X-Git-Tag: rebase--2023-08-20~5
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=c2310b7cdbadb9ef87299b1aa291064220471fba;p=demos%2Fkafka%2Fchat

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 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