From: Kai Moritz <kai@juplo.de>
Date: Fri, 14 Feb 2025 14:36:19 +0000 (+0100)
Subject: Verwendung des `ByteArraySerializer`
X-Git-Tag: spring/spring-producer--messageconverter--COMMITS--2025-02~1
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=caf1d527229d7f55ea021a12bed699e5ff72a208;p=demos%2Fkafka%2Ftraining

Verwendung des `ByteArraySerializer`
---

diff --git a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java
index 41d8b9d..4a937cd 100644
--- a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java
+++ b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java
@@ -8,8 +8,8 @@ import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.kafka.core.KafkaTemplate;
 import org.springframework.kafka.core.ProducerFactory;
+import org.springframework.kafka.support.converter.ByteArrayJsonMessageConverter;
 import org.springframework.kafka.support.converter.JsonMessageConverter;
-import org.springframework.kafka.support.converter.StringJsonMessageConverter;
 
 import java.time.Duration;
 
@@ -48,8 +48,8 @@ public class ApplicationConfiguration
   }
 
   @Bean
-  public StringJsonMessageConverter jsonMessageConverter(ObjectMapper objectMapper)
+  public ByteArrayJsonMessageConverter jsonMessageConverter(ObjectMapper objectMapper)
   {
-    return new StringJsonMessageConverter(objectMapper);
+    return new ByteArrayJsonMessageConverter(objectMapper);
   }
 }
diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml
index f5adc12..5c71180 100644
--- a/src/main/resources/application.yml
+++ b/src/main/resources/application.yml
@@ -11,6 +11,7 @@ spring:
       buffer-memory: 33554432
       batch-size: 16384
       compression-type: gzip
+      value-serializer: org.apache.kafka.common.serialization.ByteArraySerializer
       properties:
         delivery-timeout: 10s
         max-block: 5s