Commit b748ec3d authored by hangjun83's avatar hangjun83

openapi 震坤行邮件

parent e2714269
......@@ -3,6 +3,7 @@
namespace App\Support\Traits;
use App\Services\SysLogService;
use App\Support\Facades\SimpleLogs;
use longlang\phpkafka\Consumer\ConsumerConfig;
use longlang\phpkafka\Producer\ProducerConfig;
......@@ -26,7 +27,7 @@ trait KafkaConfigHelpers
$kafkaConfig->setTopic($config['topic']); // 主题名称
$client_id = uniqid(time(),true);
$kafkaConfig->setGroupId($config['groupid']); // 分组ID
app(SysLogService::class)->addApiLogs('group id is '.$config['groupid'].$client_id);
SimpleLogs::writeLog('group id is '.$config['groupid'].$client_id, 'kafka_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