From caf1d527229d7f55ea021a12bed699e5ff72a208 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Fri, 14 Feb 2025 15:36:19 +0100 Subject: [PATCH] Verwendung des `ByteArraySerializer` --- src/main/java/de/juplo/kafka/ApplicationConfiguration.java | 6 +++--- src/main/resources/application.yml | 1 + 2 files changed, 4 insertions(+), 3 deletions(-) diff --git a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java index 41d8b9da..4a937cde 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 f5adc122..5c711809 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 -- 2.20.1