应用与数据集成平台 ROMA Connect-KafkaConsumer类说明:使用示例

时间：2023-11-01 16:16:24

使用示例

importClass(com.roma.apic.livedata.client.v1.KafkaConsumer);importClass(com.roma.apic.livedata.config.v1.KafkaConfig);var kafka_brokers = '1.1.1.1:26330,2.2.2.2:26330'var topic = 'YourKafkaTopic'var group = 'YourKafkaGroupId'function execute(data) {    var config = KafkaConfig.getConfig(kafka_brokers, group)    var consumer = new KafkaConsumer(config)    var records = consumer.consume(topic, 5000, 10);    var res = []    var iter = records.iterator()    while (iter.hasNext()) {        res.push(iter.next())    }    return JSON.stringify(res);}

上一篇：应用与数据集成平台 ROMA Connect-KafkaConfig类说明:方法列表

下一篇：应用与数据集成平台 ROMA Connect-KafkaConfig类说明:方法详情