kafka_commit()

Read(239) Label: commit, object,

Description:

Commit the current consumer offset position.

Syntax:

kafka_commit (fd) 

Note:

By default, the function commits the real-time consumer offset position.

Parameters:

fd

A consumer object

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_commit(A1)

Commit the current consumer offset