From f252abf9c05f9545e0cee3d601b47fa343e65528 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Wed, 13 Sep 2023 22:54:00 +0200
Subject: [PATCH] WIP

---
 .../implementation/kafka/KafkaServicesConfiguration.java    | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

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);
     };
   }
 
-- 
2.20.1