kafka_poll()

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

描述:

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

语法:

kafka_poll (fd, timeout,[ partition1, partition2,]) 

备注:

外部库函数,获取当前topic下的记录。群集模式下的topic只能是单个;无参数partition时,遍历当前topic下所有的partition有参数partition时,timeout参数不能省略

参数:

fd

consumer对象

timeout

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

partition

群集模式下topic的分区,可以是整数或整数数组。

选项:

@c

游标查询

返回值:

序表或游标

示例:

 

A

 

1

=kafka_open("D://kafka.properties";"topic-test")

连接kafka server

2

=kafka_poll(A1)

获取topic-test下的记录

3

=kafka_poll@c(A1)

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

4

=kafka_open@c(file("D://kafka.properties");"topic-test")

群集模式连接kafka server

5

=kafka_poll(A4)

无参数partition时,遍历当前topic下所有的partition

6

=kafka_poll(A4,1000,1)

获取topic-test分区为1下的记录

7

=kafka_poll(A4,1000,[1,2])

获取topic-test分区为12下的记录