style: fix code style checks

Author: qkdreyer

pkg/rdkafka/RdKafkaProducer.php

@@ -37,7 +37,7 @@ public function send(Destination $destination, Message $message): void
         InvalidDestinationException::assertDestinationInstanceOf($destination, RdKafkaTopic::class);
         InvalidMessageException::assertMessageInstanceOf($message, RdKafkaMessage::class);
 
-        $partition = $this->getPartition($destination, $message);
+        $partition = $message->getPartition() ?? $destination->getPartition() ?? RD_KAFKA_PARTITION_UA;
         $payload = $this->serializer->toString($message);
         $key = $message->getKey() ?? $destination->getKey() ?? null;
 
@@ -122,21 +122,4 @@ public function flush(int $timeout): void
             $this->producer->flush($timeout);
         }
     }
-
-    /**
-     * @param RdKafkaTopic   $destination
-     * @param RdKafkaMessage $message
-     */
-    private function getPartition(Destination $destination, Message $message): int
-    {
-        if (null !== $message->getPartition()) {
-            return $message->getPartition();
-        }
-
-        if (null !== $destination->getPartition()) {
-            return $destination->getPartition();
-        }
-
-        return \RD_KAFKA_PARTITION_UA;
-    }
 }