Merge pull request #1532 from ozangunalp/fix_kafka_serializer_configure

Configure Kafka value serializer correctly
smallrye · Nov 26, 2021 · e4247ad · e4247ad
2 parents a781607 + 8dc6220
commit e4247ad
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);