openapi

server/app/Support/Traits/KafkaConfigHelpers.php

@@ -24,8 +24,9 @@ trait KafkaConfigHelpers
         $kafkaConfig->setBroker([$config['host'].":".$config['port']]);
         $kafkaConfig->setTopic($config['topic']); // 主题名称
         $kafkaConfig->setGroupId($config['groupid']); // 分组ID
-        //$kafkaConfig->setClientId($config['clientid']); // 客户端ID
-        //$kafkaConfig->setGroupInstanceId($config['clientid']); // 分组实例ID
+        $client_id = uniqid(time(),true);
+        $kafkaConfig->setClientId($client_id); // 客户端ID
+        $kafkaConfig->setGroupInstanceId($client_id); // 分组实例ID
 
         return $kafkaConfig;
     }