From: Kai Moritz <kai@juplo.de>
Date: Thu, 20 Apr 2023 12:27:48 +0000 (+0200)
Subject: NEU
X-Git-Tag: rebase--2023-08-18~12
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=0b917f243af8103df47a1ef76e8db59d2b90ae34;p=demos%2Fkafka%2Fchat

NEU
---

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<Integer, ChatRoomTo> record =