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 |