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

KafkaProducer类说明

分享
更新时间: 2020/07/08 GMT+08:00

路径

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

说明

生产Kafka消息。

使用示例

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
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 {
        offset: record.offset(),
        partition: record.partition(),
        code: 0,
        message: "OK"
    }
}

构造器详情

public KafkaProducer(Map configs)

构造一个Kafka消息生产者

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

方法列表

返回类型

方法和说明

org.apache.kafka.clients.producer.RecordMetadata

produce(String topic, String message)

生产消息

不能直接返回方法produce(String topic, String message),否则会导致返回信息为空。例如在使用示例中,不能直接使用“return record”句式,否则返回的信息为空。

方法详情

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

    生产消息

    输入参数

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

    返回信息

    消息记录

分享:

    相关文档

    相关产品

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

提交成功!

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

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

*必选

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

字符长度不能超过200

提交反馈 取消

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

智能客服提问云社区提问