From: Kai Moritz Date: Wed, 13 Sep 2023 21:32:42 +0000 (+0200) Subject: WIP X-Git-Tag: rebase--2023-09-14--22-59~2 X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=30efb5ca3130ef916e1523da501bc1b84b126f80;p=demos%2Fkafka%2Fchat WIP --- 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(