改名

2020-10-28 16:46:38 +08:00
parent 09a82ff676
commit 50b2ace174
1 changed files with 1 additions and 0 deletions
@@ -105,6 +105,7 @@ class Producer extends Component
 		/** @var \RdKafka\Producer $rk */
 		$rk = Snowflake::createObject(\RdKafka\Producer::class, [$this->conf]);
 		if ($rk->getOutQLen() > 0) {
+			$rk->poll(0);
 			$rk->flush($timeout);
 		}