From 0b917f243af8103df47a1ef76e8db59d2b90ae34 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Thu, 20 Apr 2023 14:27:48 +0200 Subject: [PATCH] NEU --- .../kafka/chat/backend/persistence/kafka/ChatRoomChannel.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/ChatRoomChannel.java b/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/ChatRoomChannel.java index 2a34c812..97ee9885 100644 --- a/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/ChatRoomChannel.java +++ b/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/ChatRoomChannel.java @@ -37,7 +37,7 @@ public class ChatRoomChannel implements Runnable String name) { int shard = this.shardingStrategy.selectShard(chatRoomId); - ChatRoomTo chatRoomTo = ChatRoomTo.of(chatRoomId, name, shard); + ChatRoomTo chatRoomTo = ChatRoomTo.of(chatRoomId.toString(), name, shard); return Mono.create(sink -> { ProducerRecord record = -- 2.20.1