Bugfix in RdKafkaProducer:flush() method

Avoid TypeError in `RdKafkaProducer::flush()`
php-enqueue · Apr 3, 2024 · 266a21a · 266a21a
1 parent bb6e759
commit 266a21a
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/pkg/rdkafka/RdKafkaProducer.php b/pkg/rdkafka/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;
     }
 }