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 f6e7091..b473a41 100644 (file)
--- 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(),