更新时间:2023-04-23 GMT+08:00

KafkaProducer类说明

路径

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, 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:消息内容

    返回信息

    消息记录