文档首页 > > 开发指南> 服务集成开发指导> 函数API脚本开发>

KafkaConfig类说明

KafkaConfig类说明

分享
更新时间:2021/01/26 GMT+08:00

路径

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),具体参见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对象

分享:

    相关文档

    相关产品

文档是否有解决您的问题?

提交成功!非常感谢您的反馈,我们会继续努力做到更好!
反馈提交失败,请稍后再试!

*必选

请至少选择或填写一项反馈信息

字符长度不能超过200

提交反馈 取消

如您有其它疑问,您也可以通过华为云社区论坛频道来与我们联系探讨

智能客服提问云社区提问