文档首页> 应用与数据集成平台 ROMA Connect> 开发指南（阿布扎比区域）> 服务集成开发指导> 函数API脚本开发> KafkaConfig类说明
更新时间：2022-02-21 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），具体参见MQS开发指南。

static KafkaConfig

getSaslConfig(String servers, String groupId, String username, String password)

获取一个配置，用于访问MQS提供的Kafka（开启sasl_ssl），具体参见MQS开发指南。

方法详情

  • public static KafkaConfig getConfig(String servers, String groupId)

    访问MQS提供的kafka（不开启sasl_ssl），具体参见MQS开发指南。

    输入参数

    • 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），具体参见MQS开发指南。

    输入参数

    • servers：kafkaConfig中的bootstrap.servers信息
    • groupId：kafkaConfig中的group.id信息
    • username：用户名
    • password：密码

    返回信息

    返回KafkaConfig对象

父主题： 函数API脚本开发