From: Kai Moritz <kai@juplo.de>
Date: Wed, 13 Sep 2023 20:54:00 +0000 (+0200)
Subject: WIP
X-Git-Tag: rebase--2023-09-14--22-59~5
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=f252abf9c05f9545e0cee3d601b47fa343e65528;p=demos%2Fkafka%2Fchat

WIP
---

diff --git a/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/KafkaServicesConfiguration.java b/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/KafkaServicesConfiguration.java
index 75d011f0..621ab206 100644
--- a/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/KafkaServicesConfiguration.java
+++ b/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/KafkaServicesConfiguration.java
@@ -59,13 +59,13 @@ public class KafkaServicesConfiguration
   @Bean
   KafkaServicesApplicationRunner.WorkAssignor workAssignor(
       ChatBackendProperties properties,
-      ChatRoomChannel chatRoomChannel)
+      DataChannel dataChannel)
   {
     return consumer ->
     {
       List<String> topics =
-          List.of(properties.getKafka().getChatRoomChannelTopic());
-      consumer.subscribe(topics, chatRoomChannel);
+          List.of(properties.getKafka().getDataChannelTopic());
+      consumer.subscribe(topics, dataChannel);
     };
   }