diff --git a/Kafka/Struct.php b/Kafka/Struct.php index 81020306..9476d943 100644 --- a/Kafka/Struct.php +++ b/Kafka/Struct.php @@ -12,7 +12,7 @@ class Struct public int $offset; public Message $message; - public ?string $topic; + public string $topic; public mixed $value; public int $part; diff --git a/Server/Worker/ServerWorker.php b/Server/Worker/ServerWorker.php index 133b91ae..92f49bd5 100644 --- a/Server/Worker/ServerWorker.php +++ b/Server/Worker/ServerWorker.php @@ -68,7 +68,7 @@ class ServerWorker extends \Server\Abstracts\Server private function interpretDirectory(Server $server, Annotation $annotation, $workerId) { $fileLists = $annotation->runtime(APP_PATH . 'app', - $workerId < $server->setting['worker_num'] ? [CONTROLLER_PATH] : [] + $workerId < $server->setting['worker_num'] ? [] : [CONTROLLER_PATH] ); $di = Snowflake::getDi();