From c897ca348a44cc4c7c461daefe68f7948913ff38 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Fri, 15 Sep 2023 01:38:44 +0200 Subject: [PATCH] FIX --- .../backend/implementation/kafka/KafkaChatHomeServiceTest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 1a6948fa..c46e372d 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 workAssignor(DataChannel dataChannel) + ConsumerTaskExecutor.WorkAssignor dataChannelWorkAssigner(DataChannel dataChannel) { return consumer -> { -- 2.20.1