描述:
提交当前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) |
异步提交。 |