From 30efb5ca3130ef916e1523da501bc1b84b126f80 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Wed, 13 Sep 2023 23:32:42 +0200 Subject: [PATCH] WIP --- .../backend/implementation/kafka/KafkaChatHomeServiceTest.java | 3 ++- 1 file changed, 2 insertions(+), 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 b8d7e4ba..e4a9361f 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 @@ -39,7 +39,8 @@ import static de.juplo.kafka.chat.backend.implementation.kafka.KafkaChatHomeServ "chat.backend.kafka.client-id-PREFIX=TEST", "chat.backend.kafka.bootstrap-servers=${spring.embedded.kafka.brokers}", "spring.kafka.bootstrap-servers=${spring.embedded.kafka.brokers}", - "chat.backend.kafka.chatroom-channel-topic=" + DATA_TOPIC, + "chat.backend.kafka.info-topic=" + INFO_TOPIC, + "chat.backend.kafka.data-topic=" + DATA_TOPIC, "chat.backend.kafka.num-partitions=" + NUM_SHARDS, }) @EmbeddedKafka( -- 2.20.1