Verwendung des `ByteArraySerializer`

diff --git a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java
index 41d8b9dae3f3bdab9a4811f486b869a49524da59..4a937cdec323db60aabd3466ebf5a8cfd38b19c1 100644 (file)
--- 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 f5adc1220cc5d760e526a289e881ae58e46b0973..5c711809ba28ab5218f77a11835731fd8892cc6c 100644 (file)
--- 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