描述:
获取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分区为1和2下的记录 |