From 7a5943ce46684c9b469f38780d95955a9795044c Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Sun, 5 May 2024 14:43:53 +0200 Subject: [PATCH] FIX:Type-Info --- .../de/juplo/kafka/wordcount/recorder/RecorderApplication.java | 1 + 1 file changed, 1 insertion(+) diff --git a/src/main/java/de/juplo/kafka/wordcount/recorder/RecorderApplication.java b/src/main/java/de/juplo/kafka/wordcount/recorder/RecorderApplication.java index 36a11fe..3928f2f 100644 --- a/src/main/java/de/juplo/kafka/wordcount/recorder/RecorderApplication.java +++ b/src/main/java/de/juplo/kafka/wordcount/recorder/RecorderApplication.java @@ -26,6 +26,7 @@ public class RecorderApplication props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, properties.getBootstrapServer()); props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class); props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, JsonSerializer.class); + props.put(JsonSerializer.ADD_TYPE_INFO_HEADERS, false); return new KafkaProducer<>(props); } -- 2.20.1