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 f6e709120d455a32bf51779d4b00f3dc4aeb1190..b473a418f687d8ae1d04bb15cd7ae034329f620e 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(),