X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fchat%2Fbackend%2FKafkaConfigurationIT.java;h=ea304412490f25e17985ef9e19bf030f5608beed;hb=e0a5101e5d6cac4002e18c48be9a5c6d9d3a898d;hp=961275e88d521b289d06668c02c28f444f093a60;hpb=2ccf8e29b0ffb2366a717392fa996707fde1821d;p=demos%2Fkafka%2Fchat diff --git a/src/test/java/de/juplo/kafka/chat/backend/KafkaConfigurationIT.java b/src/test/java/de/juplo/kafka/chat/backend/KafkaConfigurationIT.java index 961275e8..ea304412 100644 --- a/src/test/java/de/juplo/kafka/chat/backend/KafkaConfigurationIT.java +++ b/src/test/java/de/juplo/kafka/chat/backend/KafkaConfigurationIT.java @@ -36,7 +36,7 @@ import static de.juplo.kafka.chat.backend.KafkaConfigurationIT.TOPIC; @Slf4j class KafkaConfigurationIT extends AbstractConfigurationWithShardingIT { - final static String TOPIC = "TEST_CHATROOM_CHANNEL"; + final static String TOPIC = "KAFKA_CONFIGURATION_IT"; static CompletableFuture CONSUMER_JOB;