改名

2020-10-28 16:41:33 +08:00
parent 4aababe7c5
commit 41b253d172
1 changed files with 0 additions and 1 deletions
@@ -106,7 +106,6 @@ class Producer extends Component
 		$topic = $rk->newTopic($this->_topic, $this->topicConf);
 		$topic->produce(RD_KAFKA_PARTITION_UA, 0, $message, $key);
 		$rk->poll($timeout);
-		$rk->flush($timeout);

 		$event = Snowflake::app()->getEvent();
 		$event->on(Event::EVENT_AFTER_REQUEST, [$this,'onFlush'], [$rk, $timeout]);