更新时间：2023-05-17 GMT+08:00
KafkaConfig类说明
路径
com.roma.apic.livedata.config.v1.KafkaConfig
extends
java.util.Properties
说明
与KafkaProducer或KafkaConsumer配合使用，对Kafka客户端进行配置。
构造器详情
public KafkaConfig()
构造一个无参数的KafkaConfig
方法列表
|
返回类型 |
方法和说明 |
|---|---|
|
static KafkaConfig |
getConfig(String servers, String groupId) 获取一个配置，用于访问MQS提供的Kafka（不开启sasl_ssl）。 |
|
static KafkaConfig |
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对象
父主题： 自定义后端开发（函数后端）
