文档首页 > > 开发指南> APIC开发指南> Function API中类的使用说明> KafkaProducer

KafkaProducer

分享
更新时间: 2019/08/28 GMT+08:00

路径

com.roma.apic.livedata.client.v1.KafkaProducer

说明

生产Kafka消息。

使用示例

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
importClass(com.roma.apic.livedata.client.v1.KafkaProducer);
importClass(com.roma.apic.livedata.config.v1.KafkaConfig);

var kafka_brokers = '1.1.1.1:26330,2.2.2.2:26330'
var topic = 'YourKafkaTopic'

function execute(data) {
    var config = KafkaConfig.getConfig(kafka_brokers, null)
    var producer = new KafkaProducer(config)
    var record = producer.produce(topic, "hello, dms kafka.")
    return record.offset()
}

构造器详情

public KafkaProducer(Map configs)

构造一个Kafka消息生产者

参数:configs表示Kafka的配置信息

方法列表

返回类型

方法和说明

org.apache.kafka.clients.producer.RecordMetadata

produce(String topic, String message)

生产消息

方法详情

  • public org.apache.kafka.clients.producer.RecordMetadata produce(String topic, String message)

    生产消息

    输入参数

    • topic:消息队列
    • message:消息内容

    返回信息

    消息记录

    抛出异常

    • concurrent.ExecutionException
    • InterruptedException
分享:

    相关文档

    相关产品

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

提交成功!

非常感谢您的反馈,我们会继续努力做到更好!

反馈提交失败,请稍后再试!

*必选

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

字符长度不能超过200

提交反馈 取消

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

跳转到云社区