Description:
Return records in a Consumer topic as a table sequence.
Syntax:
kafka_poll (fd, timeout)
Note:
The function gets records of the current Consumer topic.
Parameters:
|
fd |
A Consumer object |
|
timeout |
The interval of consumer poll loop; default is 1000ms |
Options:
|
@c |
Enable a cursor-based query |
Return value:
Table sequence or cursor
Example:
|
|
A |
|
|
1 |
=kafka_subscribe("D:/kafka_string.properties";"topic-test";"String","byte[]") |
Connect to Kafka server |
|
2 |
=kafka_poll(A1) |
Get records from topic test1 |
|
3 |
=kafka_poll@c(A1) |
Get records from topic test1 with cursor |