Skip to content

Commit 266a21a

Browse files
Bugfix in RdKafkaProducer:flush() method
Avoid TypeError in `RdKafkaProducer::flush()`
1 parent bb6e759 commit 266a21a

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

pkg/rdkafka/RdKafkaProducer.php

+2
Original file line numberDiff line numberDiff line change
@@ -121,5 +121,7 @@ public function flush(int $timeout): ?int
121121
if (method_exists($this->producer, 'flush')) {
122122
return $this->producer->flush($timeout);
123123
}
124+
125+
return null;
124126
}
125127
}

0 commit comments

Comments
 (0)