X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fchat%2Fbackend%2FKafkaConfigurationIT.java;h=ea304412490f25e17985ef9e19bf030f5608beed;hb=df207aa9a8cd349fd43785270d250a7f55593801;hp=961275e88d521b289d06668c02c28f444f093a60;hpb=e7af512057440075a779ff5a5401dd11fc962741;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;