kafka_commit()

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

描述:

提交当前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