diff --git a/src/Messenger/KafkaTransport.php b/src/Messenger/KafkaTransport.php index ed87f78..5e22e4e 100644 --- a/src/Messenger/KafkaTransport.php +++ b/src/Messenger/KafkaTransport.php @@ -79,7 +79,7 @@ private function getSender(): KafkaSender private function getReceiver(): KafkaReceiver { - return $this->receiver ?? $this->sender = new KafkaReceiver( + return $this->receiver ?? $this->receiver = new KafkaReceiver( $this->logger, $this->serializer, $this->rdKafkaFactory,