From 8dc622057feceab2181e079b743b8118b00854cf Mon Sep 17 00:00:00 2001
From: Ozan Gunalp <ozangunalp@gmail.com>
Date: Fri, 26 Nov 2021 15:20:25 +0300
Subject: [PATCH] Configure Kafka value serializer correctly

---
 .../reactive/messaging/kafka/impl/ReactiveKafkaProducer.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/smallrye-reactive-messaging-kafka/src/main/java/io/smallrye/reactive/messaging/kafka/impl/ReactiveKafkaProducer.java b/smallrye-reactive-messaging-kafka/src/main/java/io/smallrye/reactive/messaging/kafka/impl/ReactiveKafkaProducer.java
index 26aac29264..ec4c46c992 100644
--- a/smallrye-reactive-messaging-kafka/src/main/java/io/smallrye/reactive/messaging/kafka/impl/ReactiveKafkaProducer.java
+++ b/smallrye-reactive-messaging-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);