Commit e82e0d4e authored by hangjun83's avatar hangjun83

openapi

parent 7c7d634e
...@@ -24,8 +24,8 @@ trait KafkaConfigHelpers ...@@ -24,8 +24,8 @@ trait KafkaConfigHelpers
$kafkaConfig->setBroker([$config['host'].":".$config['port']]); $kafkaConfig->setBroker([$config['host'].":".$config['port']]);
$kafkaConfig->setTopic($config['topic']); // 主题名称 $kafkaConfig->setTopic($config['topic']); // 主题名称
$kafkaConfig->setGroupId($config['groupid']); // 分组ID $kafkaConfig->setGroupId($config['groupid']); // 分组ID
$kafkaConfig->setClientId($config['clientid']); // 客户端ID //$kafkaConfig->setClientId($config['clientid']); // 客户端ID
$kafkaConfig->setGroupInstanceId($config['clientid']); // 分组实例ID //$kafkaConfig->setGroupInstanceId($config['clientid']); // 分组实例ID
return $kafkaConfig; return $kafkaConfig;
} }
......
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