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 (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 f5adc12..5c71180 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