From: Kai Moritz <kai@juplo.de>
Date: Fri, 18 Aug 2023 13:49:23 +0000 (+0200)
Subject: NG
X-Git-Tag: rebase--2023-08-18-abends~10
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=3bd9103fc8b783ac8d5161f63dbffb57e42ff765;p=demos%2Fkafka%2Fchat

NG
---

diff --git a/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/ChatMessageChannel.java b/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/ChatMessageChannel.java
index f6e70912..b473a418 100644
--- a/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/ChatMessageChannel.java
+++ b/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/ChatMessageChannel.java
@@ -79,7 +79,7 @@ public class ChatMessageChannel implements Runnable, ConsumerRebalanceListener
     CreateChatRoomRequestTo createChatRoomRequestTo = CreateChatRoomRequestTo.of(name);
     return Mono.create(sink ->
     {
-      ProducerRecord<String, CreateChatRoomRequestTo> record =
+      ProducerRecord<String, AbstractTo> record =
           new ProducerRecord<>(
               topic,
               chatRoomId.toString(),