openapi

server/app/Console/Commands/KafkaConsumerCommand.php

@@ -39,7 +39,6 @@ class KafkaConsumerCommand extends Command
      */
     public function handle()
     {
-
         if (! $this->confirmToProceed()) {
             return 1;
         }

server/app/Support/Traits/KafkaConfigHelpers.php

@@ -14,7 +14,7 @@ trait KafkaConfigHelpers
     {
         $kafkaConfig = app(ProducerConfig::class);
         $kafkaConfig->setBootstrapServer($config['host'].":".$config['port']);
-        $kafkaConfig->setUpdateBrokers(true);
+        $kafkaConfig->setUpdateBrokers(false);
         $kafkaConfig->setAcks(-1);
 
         return $kafkaConfig;
@@ -27,7 +27,7 @@ trait KafkaConfigHelpers
         $kafkaConfig->setTopic($config['topic']); // 主题名称
         $client_id = uniqid(time(),true);
         $kafkaConfig->setGroupId($config['groupid']); // 分组ID
-        SimpleLogs::writeLog('group id is '.$config['groupid'].$client_id, 'kafka_client_id');
+        //SimpleLogs::writeLog('group id is '.$config['groupid'].$client_id, 'kafka_client_id');
         $kafkaConfig->setClientId($client_id); // 客户端ID
         $kafkaConfig->setGroupInstanceId($client_id); // 分组实例ID
 

server/composer.json

@@ -12,7 +12,6 @@
         "guzzlehttp/guzzle": "^7.3",
         "illuminate/redis": "^8.34",
         "jiannei/laravel-enum": "^3.0",
-        "jiannei/laravel-logger": "^1.2",
         "jiannei/laravel-response": "^4.0",
         "laravel/lumen-framework": "^8.0",
         "laravelista/lumen-vendor-publish": "^8.0",
@@ -22,7 +21,8 @@
         "prettus/l5-repository": "^2.7",
         "spatie/laravel-cronless-schedule": "^1.1",
         "spatie/laravel-permission": "^5.1",
-        "tymon/jwt-auth": "^1.0.2"
+        "tymon/jwt-auth": "^1.0.2",
+        "illuminate/mail":"^8.2"
     },
     "require-dev": {
         "fzaninotto/faker": "^1.9.1",

server/config/kafka.php

@@ -7,7 +7,7 @@ return [
     'kafka' => [
         'host' => env('KAFKA_HOST', '127.0.0.1'),
         'port' => env('KAFKA_PORT', '9092'),
-        'topic' => env('KAFKA_TOPIC', 'system_channel'),
+        'topic' => env('KAFKA_TOPIC', 'openapi_channel'),
         'groupid' => env('KAFKA_GROUPID', 'apiGroup'),
         'clientid' => env('KAFKA_CLIENTID', 'apiGroup'),
     ],