NG

diff --git a/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/KafkaServicesConfiguration.java b/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/KafkaServicesConfiguration.java
index 4ebed8d..4f6e918 100644 (file)
--- a/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/KafkaServicesConfiguration.java
+++ b/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/KafkaServicesConfiguration.java
@@ -48,24 +48,6 @@ public class KafkaServicesConfiguration
     return new KafkaChatRoomFactory(chatMessageChannel);
   }
 
-  @Bean
-  Producer<Integer, CreateChatRoomRequestTo>  chatRoomChannelProducer(
-      Properties defaultProducerProperties,
-      ChatBackendProperties chatBackendProperties,
-      IntegerSerializer integerSerializer,
-      JsonSerializer<CreateChatRoomRequestTo> chatRoomSerializer)
-  {
-    Map<String, Object> properties = new HashMap<>();
-    defaultProducerProperties.forEach((key, value) -> properties.put(key.toString(), value));
-    properties.put(
-        ProducerConfig.CLIENT_ID_CONFIG,
-        chatBackendProperties.getKafka().getClientIdPrefix() + "_CHATROOM_CHANNEL_PRODUCER");
-    return new KafkaProducer<>(
-        properties,
-        integerSerializer,
-        chatRoomSerializer);
-  }
-
   @Bean
   KafkaLikeShardingStrategy shardingStrategy(ChatBackendProperties properties)
   {

diff --git a/src/test/java/de/juplo/kafka/chat/backend/persistence/kafka/CreateChatRoomRequestToTest.java b/src/test/java/de/juplo/kafka/chat/backend/persistence/kafka/CreateChatRoomRequestToTest.java
index a917c9f..c5e6935 100644 (file)
--- a/src/test/java/de/juplo/kafka/chat/backend/persistence/kafka/CreateChatRoomRequestToTest.java
+++ b/src/test/java/de/juplo/kafka/chat/backend/persistence/kafka/CreateChatRoomRequestToTest.java
@@ -13,7 +13,7 @@ public class CreateChatRoomRequestToTest
 {
   final String json = """
   {
-    "name": "Foo-Room!",
+    "name": "Foo-Room!"
   }""";
 
   ObjectMapper mapper;