Commit ec0f0218 authored by hangjun83's avatar hangjun83

openapi

parent cc5bf011
......@@ -2,6 +2,7 @@
namespace App\Support\Traits;
use App\Services\SysLogService;
use longlang\phpkafka\Consumer\ConsumerConfig;
use longlang\phpkafka\Producer\ProducerConfig;
......@@ -25,6 +26,7 @@ trait KafkaConfigHelpers
$kafkaConfig->setTopic($config['topic']); // 主题名称
$client_id = uniqid(time(),true);
$kafkaConfig->setGroupId($config['groupid'].$client_id); // 分组ID
app(SysLogService::class)->addApiLogs('group id is '.$config['groupid'].$client_id);
//$kafkaConfig->setClientId($client_id); // 客户端ID
//$kafkaConfig->setGroupInstanceId($client_id); // 分组实例ID
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment