From a05eccbc84743f5309da2d39fff22fc48763f781 Mon Sep 17 00:00:00 2001
From: alexbusu-motork <149699605+alexbusu-motork@users.noreply.github.com>
Date: Wed, 3 Apr 2024 12:21:33 +0100
Subject: [PATCH] Update RdKafkaProducer.php

Avoid TypeError in `RdKafkaProducer::flush()`
---
 RdKafkaProducer.php | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/RdKafkaProducer.php b/RdKafkaProducer.php
index 64b9ea3..69411df 100644
--- a/RdKafkaProducer.php
+++ b/RdKafkaProducer.php
@@ -121,5 +121,7 @@ public function flush(int $timeout): ?int
         if (method_exists($this->producer, 'flush')) {
             return $this->producer->flush($timeout);
         }
+
+        return null;
     }
 }