From: Kai Moritz Date: Wed, 28 Feb 2024 21:43:28 +0000 (+0100) Subject: test: HandoverIT-POC - Fixed illegal client-naming (one character only) X-Git-Url: https://juplo.de/gitweb/?a=commitdiff_plain;ds=sidebyside;h=49c29d08549c5915301e9f95224edf64d101f272;p=demos%2Fkafka%2Fchat test: HandoverIT-POC - Fixed illegal client-naming (one character only) --- diff --git a/src/test/java/de/juplo/kafka/chat/backend/AbstractHandoverIT.java b/src/test/java/de/juplo/kafka/chat/backend/AbstractHandoverIT.java index 18e15b40..19d69049 100644 --- a/src/test/java/de/juplo/kafka/chat/backend/AbstractHandoverIT.java +++ b/src/test/java/de/juplo/kafka/chat/backend/AbstractHandoverIT.java @@ -43,12 +43,12 @@ public abstract class AbstractHandoverIT { ChatRoomInfoTo[] chatRooms = Flux .range(0, NUM_CHATROOMS) - .flatMap(i -> createChatRoom("#" + i)) + .flatMap(i -> createChatRoom("room-" + i)) .toStream() .toArray(size -> new ChatRoomInfoTo[size]); TestClient[] testClients = Flux - .fromStream(IntStream.range(0, NUM_CLIENTS).mapToObj(i -> Integer.toString(i))) + .fromStream(IntStream.range(0, NUM_CLIENTS).mapToObj(i -> "user-" + Integer.toString(i))) .map(i -> new TestClient( containers.haproxy.getMappedPort(8400), chatRooms,