Merge pull request #1310 from felippeduarte/master

Set return type to flush function in RdkafkaProducer to be compatible to php-rdkafka

Author: makasim

pkg/rdkafka/RdKafkaProducer.php

@@ -115,11 +115,11 @@ public function getTimeToLive(): ?int
         return null;
     }
 
-    public function flush(int $timeout): void
+    public function flush(int $timeout): ?int
     {
         // Flush method is exposed in phprdkafka 4.0
         if (method_exists($this->producer, 'flush')) {
-            $this->producer->flush($timeout);
+            return $this->producer->flush($timeout);
         }
     }
 }