as2252258/kiri-core
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity

改名

Browse Source
This commit is contained in:
Mr·x
2020-10-28 16:42:15 +08:00
parent 41b253d172
commit 14c052a3b2
1 changed files with 0 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Kafka/Producer.php
-14
View File
@@ -106,20 +106,6 @@ class Producer extends Component
$topic = $rk->newTopic($this->_topic, $this->topicConf); $topic = $rk->newTopic($this->_topic, $this->topicConf);
$topic->produce(RD_KAFKA_PARTITION_UA, 0, $message, $key); $topic->produce(RD_KAFKA_PARTITION_UA, 0, $message, $key);
$rk->poll($timeout); $rk->poll($timeout);
$event = Snowflake::app()->getEvent();
$event->on(Event::EVENT_AFTER_REQUEST, [$this,'onFlush'], [$rk, $timeout]);
}
/**
* @param $rk
* @param $timeout
*/
public function onFlush($rk, $timeout)
{
var_dump($rk, $timeout);
$this->debug(Event::EVENT_AFTER_REQUEST);
$rk->flush($timeout); $rk->flush($timeout);
} }
} }