描述:
提交当前consumer offset的位置。
语法:
kafka_commit (fd)
备注:
外部库函数,缺省时为同步提交当前consumer offset的位置。
参数:
fd |
连接对象 |
选项:
@a |
异步提交 |
示例:
|
A |
|
1 |
=kafka_open("D://kafka.properties","topic-test") |
连接kafka server |
2 |
=kafka_poll(A1) |
获取topic-test下的记录 |
3 |
=kafka_commit(A1) |
同步当前consumer offset |
4 |
=kafka_commit@a(A1) |
异步提交 |