Whoops 😬

linkedin · Dec 12, 2024 · d3ae029 · d3ae029
1 parent b69a883
commit d3ae029
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/internal/venice-common/src/main/java/com/linkedin/venice/writer/VeniceWriter.java b/internal/venice-common/src/main/java/com/linkedin/venice/writer/VeniceWriter.java
@@ -952,7 +952,7 @@ public CompletableFuture<PubSubProduceResult> put(
     KafkaKey kafkaKey = new KafkaKey(MessageType.PUT, serializedKey);
 
     // Initialize the SpecificRecord instances used by the Avro-based Kafka protocol
-    Put putPayload = buildPutPayload(serializedKey, valueSchemaId, putMetadata);
+    Put putPayload = buildPutPayload(serializedValue, valueSchemaId, putMetadata);
     CompletableFuture<PubSubProduceResult> produceResultFuture = sendMessage(
         producerMetadata -> kafkaKey,
         MessageType.PUT,