改名

2020-10-12 12:59:29 +08:00
parent 3d09da1688
commit 3235033c93
1 changed files with 2 additions and 2 deletions
@@ -78,8 +78,8 @@ class Kafka extends \Snowflake\Process\Process
 					defer(function () use ($group) {
 						$group->done();
 					});
-					while ([$topic, $part, $message] = $this->channel->pop()) {
+					while ($messages = $this->channel->pop()) {
-						$this->handlerExecute($topic, $part, $message);
+						$this->handlerExecute($messages[0], $messages[1], $messages[2]);
 					}
 				});
 			}