Set key if available

KonstantinCodes · Jun 27, 2020 · f088800 · f088800
1 parent 3171fb0
commit f088800
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/Messenger/KafkaTransport.php b/Messenger/KafkaTransport.php
@@ -143,7 +143,7 @@ public function send(Envelope $envelope): Envelope
 
         $payload = $this->serializer->encode($envelope);
 
-        $topic->producev(RD_KAFKA_PARTITION_UA, 0, $payload['body'], null, $payload['headers'] ?? null);
+        $topic->producev(RD_KAFKA_PARTITION_UA, 0, $payload['body'], $payload['key'] ?? null, $payload['headers'] ?? null);
 
         $producer->flush($this->flushTimeoutMs);