kafka_poll()

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

描述:

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

语法:

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

备注:

外部库函数,外部库的使用请参考《外部库使用指南》。

获取当前topic下的记录。无参数partition时,遍历当前topic下所有的分区。

参数:

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).fetch()

游标方式获取记录。

4

=kafka_poll(A1,2000)

 

5

=kafka_open (file("D://kafka.properties"),"topic-test1")

 

6

=kafka_offset(A5,2,0)

topic-test1分区0下的记录设置位移为2

7

=kafka_poll(A5,1000,0)

获取分区0下的记录。

8

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

获取分区1和分区2下的记录。

9

=kafka_close(A1)