更新时间:2023-04-23 GMT+08:00
KafkaConsumer类说明
路径
com.roma.apic.livedata.client.v1.KafkaConsumer
说明
消费Kafka消息。
使用示例
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 |
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); } |
构造器详情
public KafkaConsumer(Map configs)
构造一个Kafka消息消费者
参数:configs表示Kafka的配置信息
方法列表
返回类型 |
方法和说明 |
---|---|
List<String> |
consume(String topic, long timeout, long maxItems) 消费消息 |
父主题: 函数API脚本开发