kafka_poll()

Read(2387) Label: get records, table sequence, cursor,

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))