Description:
Return records in a Consumer topic as a table sequence.
Syntax:
kafka_poll (fd, timeout,[partition1, partition2,…])
Note:
The external library function (See External Library Guide) gets records of the current Consumer topic. The function traverses all partitions in the topic when parameter partition is absent.
Parameter:
|
fd |
A Consumer object |
|
timeout |
The interval of consumer poll loop; default is 1000ms |
|
partition |
The number of partitions in a topic, which is an integer or a sequence |
Option:
|
@c |
Enable a cursor-based query |
Return value:
Table sequence or cursor
Example:
|
|
A |
|
|
1 |
=kafka_open("D://kafka.properties","topic-test") |
Connect to Kafka server. |
|
2 |
=kafka_poll(A1) |
Get records from topictest. |
|
3 |
=kafka_poll@c(A1).fetch() |
Get records in the way of cursor. |
|
4 |
=kafka_poll(A1,2000) |
|
|
5 |
=kafka_open(file("D://kafka.properties"),"topic-test1") |
|
|
6 |
=kafka_offset(A5,2,0) |
Set offset as 2 for records in partition0 in topic-test1. |
|
7 |
=kafka_poll(A5,1000,0) |
Get records in partition0. |
|
8 |
=kafka_poll(A5,1000,[1,2]) |
Get records in partition1 and partition2. |
|
9 |
=kafka_ close(A1)) |
|