diff --git a/Kafka/Producer.php b/Kafka/Producer.php index b9cd8229..8380cf8e 100644 --- a/Kafka/Producer.php +++ b/Kafka/Producer.php @@ -119,6 +119,7 @@ class Producer extends Component */ public function onFlush($rk, $timeout) { + var_dump($rk, $timeout); $this->debug(Event::EVENT_AFTER_REQUEST); $rk->flush($timeout); }