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:31:04 +08:00
parent 6fda19d2bc
commit d028da2dd0
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Kafka/Producer.php
+4 -1
View File
@@ -106,9 +106,12 @@ 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);
$rk->flush($timeout);
$event = Snowflake::app()->getEvent(); $event = Snowflake::app()->getEvent();
$event->on(Event::EVENT_AFTER_REQUEST, [$this, 'onFlush']); $event->on(Event::EVENT_AFTER_REQUEST, function ($rk, $timeout) {
var_dump(func_get_args());
}, [$rk, $timeout]);
} }