From 46f0fd72e957a4071737c80d1fb4d0d1db21b8c1 Mon Sep 17 00:00:00 2001
From: Felippe Roberto Bayestorff Duarte <felippeduarte@gmail.com>
Date: Tue, 8 Aug 2023 17:59:25 -0300
Subject: [PATCH] Add return type to flush function in RdkafkaProducer to be
 compatible to php-rdkafka flush function

---
 pkg/rdkafka/RdKafkaProducer.php | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/pkg/rdkafka/RdKafkaProducer.php b/pkg/rdkafka/RdKafkaProducer.php
index a3c977f83..64b9ea3a7 100644
--- a/pkg/rdkafka/RdKafkaProducer.php
+++ b/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);
         }
     }
 }