From e400c437b999e1e92f2a52e3ef72306a9107aff9 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Thu, 20 Apr 2023 17:36:11 +0200 Subject: [PATCH] NEU --- .../chat/backend/persistence/kafka/ChatMessageChannel.java | 2 +- .../backend/persistence/kafka/KafkaServicesConfiguration.java | 0 2 files changed, 1 insertion(+), 1 deletion(-) rename src/{test => main}/java/de/juplo/kafka/chat/backend/persistence/kafka/KafkaServicesConfiguration.java (100%) diff --git a/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/ChatMessageChannel.java b/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/ChatMessageChannel.java index 43ea3994..1925cc88 100644 --- a/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/ChatMessageChannel.java +++ b/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/ChatMessageChannel.java @@ -154,7 +154,7 @@ public class ChatMessageChannel implements Runnable, ConsumerRebalanceListener @Override public void run() { - consumer.subscribe(List.of(topic)); + consumer.subscribe(List.of(topic), this); running = true; diff --git a/src/test/java/de/juplo/kafka/chat/backend/persistence/kafka/KafkaServicesConfiguration.java b/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/KafkaServicesConfiguration.java similarity index 100% rename from src/test/java/de/juplo/kafka/chat/backend/persistence/kafka/KafkaServicesConfiguration.java rename to src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/KafkaServicesConfiguration.java -- 2.20.1