openapi 震坤行

server/app/Services/Kafka/KafkaService.php

@@ -43,11 +43,9 @@ class KafkaService
             $producer = new Producer($this->kafkaProducerConfig);
             $producer->send($kafkaTopic, json_encode($contentValue), $key);
 
-            app(SysLogService::class)->addOperationLogs(
-                [
-                    'content' => $contentValue
-                ]
-            );
+            SimpleLogs::writeLog([
+                'content' => $contentValue
+            ],__CLASS__.':produerSend');
 
         } catch (\Exception $exception) {
             $this->errLog($exception);