描述：
提交当前consumer offset的位置。
语法：
kafka_commit (fd)
备注：
缺省时为同步提交当前consumer offset的位置。
参数：
|
fd |
consumer对象 |
示例：
|
|
A |
|
|
1 |
=kafka_subscribe("D:/kafka_string.properties";"topic-test";"String","byte[]") |
连接kafka server |
|
2 |
=kafka_poll(A1) |
获取topic test1下的记录 |
|
3 |
=kafka_commit(A1) |
同步当前consumer offset |