From: Kai Moritz <kai@juplo.de>
Date: Thu, 14 Sep 2023 23:14:52 +0000 (+0200)
Subject: WIP:ALIGN
X-Git-Tag: rebase--2023-09-15--10-15~5
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=5a5cfe486284e2d751543271a37d4da0b50dd635;p=demos%2Fkafka%2Fchat

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 577355e5..1a6948fa 100644
--- 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
@@ -59,13 +59,14 @@ public class KafkaChatHomeServiceTest extends ChatHomeServiceWithShardsTest
   static class KafkaChatHomeTestConfiguration
   {
     @Bean
-    ConsumerTaskExecutor.WorkAssignor workAssignor()
+    ConsumerTaskExecutor.WorkAssignor workAssignor(DataChannel dataChannel)
     {
       return consumer ->
       {
         List<TopicPartition> assignedPartitions =
             List.of(new TopicPartition(DATA_TOPIC, 2));
         consumer.assign(assignedPartitions);
+        dataChannel.onPartitionsAssigned(assignedPartitions);
       };
     }