From 3bd9103fc8b783ac8d5161f63dbffb57e42ff765 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Fri, 18 Aug 2023 15:49:23 +0200
Subject: [PATCH] NG

---
 .../chat/backend/persistence/kafka/ChatMessageChannel.java      | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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(),
-- 
2.20.1