更新时间:2023-05-17 GMT+08:00
分享

KafkaConfig类说明

路径

com.roma.apic.livedata.config.v1.KafkaConfig

extends

java.util.Properties

说明

KafkaProducerKafkaConsumer配合使用,对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对象

相关文档