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