openapi

server/app/Support/Traits/KafkaConfigHelpers.php

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