Configure Kafka value serializer correctly

smallrye · Nov 26, 2021 · 8dc6220 · 8dc6220
1 parent a781607
commit 8dc6220
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...-kafka/src/main/java/io/smallrye/reactive/messaging/kafka/impl/ReactiveKafkaProducer.java b/...-kafka/src/main/java/io/smallrye/reactive/messaging/kafka/impl/ReactiveKafkaProducer.java
@@ -83,7 +83,7 @@ public ReactiveKafkaProducer(Map<String, Object> kafkaConfiguration, String chan
 
         // Configure the underlying serializers
         keySerializer.configure(kafkaConfiguration, true);
-        valueSerializer.configure(kafkaConfiguration, true);
+        valueSerializer.configure(kafkaConfiguration, false);
 
         kafkaWorker = Executors.newSingleThreadExecutor(KafkaSendingThread::new);
         producer = new KafkaProducer<>(kafkaConfiguration, keySerializer, valueSerializer);