文档首页/ 应用与数据集成平台 ROMA Connect/ 开发指南/ 服务集成开发指导/ 自定义后端开发（函数后端）/ KafkaConfig类说明
更新时间：2023-05-17 GMT+08:00
查看PDF
分享

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对象

相关文档