描述:
获取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下的记录 |