openapi

server/app/Support/Traits/KafkaConfigHelpers.php

@@ -25,10 +25,10 @@ trait KafkaConfigHelpers
         $kafkaConfig->setBroker([$config['host'].":".$config['port']]);
         $kafkaConfig->setTopic($config['topic']); // 主题名称
         $client_id = uniqid(time(),true);
-        $kafkaConfig->setGroupId($config['groupid'].$client_id); // 分组ID
+        $kafkaConfig->setGroupId($config['groupid']); // 分组ID
         app(SysLogService::class)->addApiLogs('group id is '.$config['groupid'].$client_id);
-        //$kafkaConfig->setClientId($client_id); // 客户端ID
-        //$kafkaConfig->setGroupInstanceId($client_id); // 分组实例ID
+        $kafkaConfig->setClientId($client_id); // 客户端ID
+        $kafkaConfig->setGroupInstanceId($client_id); // 分组实例ID
 
         return $kafkaConfig;
     }