From: Kai Moritz Date: Thu, 14 Sep 2023 23:41:30 +0000 (+0200) Subject: FIX X-Git-Tag: rebase--2023-09-15--10-15~2 X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=296c13f230ab6fed253286fc2eb639018ef6a928;p=demos%2Fkafka%2Fchat FIX --- 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 c46e372d..e1e6710f 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,7 +59,7 @@ public class KafkaChatHomeServiceTest extends ChatHomeServiceWithShardsTest static class KafkaChatHomeTestConfiguration { @Bean - ConsumerTaskExecutor.WorkAssignor dataChannelWorkAssigner(DataChannel dataChannel) + ConsumerTaskExecutor.WorkAssignor dataChannelWorkAssignor(DataChannel dataChannel) { return consumer -> {