kafka_commit()

阅读(570) 标签: 提交, 对象,

描述:

提交当前consumer offset的位置。

语法:

kafka_commit (fd) 

备注:

外部库函数,缺省时为同步提交当前consumer offset的位置

参数:

fd

consumer对象

选项:

@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)

异步提交