KafkaProducer类说明

路径

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

说明

生产Kafka消息。

使用示例

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的配置信息

方法列表

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

方法详情

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

生产消息

输入参数

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

返回信息

消息记录