]> juplo.de Git - demos/kafka/chat/commitdiff
FIX
authorKai Moritz <kai@juplo.de>
Thu, 14 Sep 2023 23:41:30 +0000 (01:41 +0200)
committerKai Moritz <kai@juplo.de>
Thu, 14 Sep 2023 23:41:30 +0000 (01:41 +0200)
src/test/java/de/juplo/kafka/chat/backend/implementation/kafka/KafkaChatHomeServiceTest.java

index c46e372db2cd9cd64570732b214af017fbb18d7e..e1e6710fae769767289b5ee01fa8ef9fa3ecf1e9 100644 (file)
@@ -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 ->
       {