
# KafkaConfig类说明
#### 路径
com.roma.apic.livedata.config.v1.KafkaConfig
extends
java.util.Properties
#### 说明
与[KafkaProducer](https://support.huaweicloud.com/devg-roma/apic-dev-190603042.html)或[KafkaConsumer](https://support.huaweicloud.com/devg-roma/apic-dev-190603041.html)配合使用，对Kafka客户端进行配置。
#### 构造器详情
**public KafkaConfig()**
构造一个无参数的KafkaConfig
#### 方法列表
| 返回类型                                                                                    | 方法和说明                                                                                                                                                                                          |
|:---|:---|
| static [KafkaConfig](https://support.huaweicloud.com/devg-roma/apic-dev-190603043.html) | [getConfig](String servers, String groupId) 获取一个配置，用于访问MQS提供的Kafka（不开启sasl_ssl）。                                       |
| static [KafkaConfig](https://support.huaweicloud.com/devg-roma/apic-dev-190603043.html) | [getSaslConfig](String servers, String groupId, String username, String password) 获取一个配置，用于访问MQS提供的Kafka（开启sasl_ssl）。 |
   
#### 方法详情
- **public static** **KafkaConfig** **getConfig(String servers, String groupId)**
  访问MQS提供的kafka（不开启sasl_ssl）。
  **输入参数**
  - servers：kafkaConfig中的bootstrap.servers信息
  
  - groupId：kafkaConfig中的group.id信息
  
  
  **返回信息**
  返回KafkaConfig对象
  
- **public static** **KafkaConfig** **getSaslConfig(String servers, String groupId, String username, String password)**
  访问MQS提供的kafka（开启sasl_ssl）。
  **输入参数**
  - servers：kafkaConfig中的bootstrap.servers信息
  
  - groupId：kafkaConfig中的group.id信息
  
  - username：用户名
  
  - password：密码
  
  
  **返回信息**
  返回KafkaConfig对象
  
 
