kafka_poll()

阅读(664) 标签: 获取记录, 序表, 游标,

描述:

获取consumer消息记录, 返回序表

语法:

kafka_poll (fd, timeout) 

备注:

获取当前topic下的记录。

参数:

fd

consumer对象

timeout

poll循环间隔时间,缺省为1000ms

选项:

@c

游标查询

返回值:

序表或游标

示例:

 

A

 

1

=kafka_subscribe("D:/kafka_string.properties";"topic-test";"String","byte[]")

连接kafka server

2

=kafka_poll(A1)

获取topic test1下的记录

3

=kafka_poll@c(A1)

以游标方式获取topic test1下的记录