kafka_offset ()

阅读(42) 标签: 消费组, 主题分区, 位移,

描述:

设置消费组当前主题分区的位移。

语法:

kafka_offset(fd, offset)

kafka_offset(fd, offset,[partition1, partition2,…])

kafka_offset(fd, [partitionOffset1, partitionOffset2,…])

备注:

外部库函数,若只有offset参数时,则对当前主题所有分区设置位移,否则对指定的分区设置位移;参数为[partitionOffset1,…]时,与分区序列对应。

参数:

fd

consumer对象

offset

消费者组(consumer group)的位移值

partition

主题的分区索引号

partitionOffset

要设置的分区位移值

返回值:

布尔值

示例:

 

A

 

1

=kafka_open("D://kafka.properties","topic-test")

连接kafka server

2

=kafka_offset(A1,10)

topic-test中所有分区设置位移

3

=kafka_offset(A1,10,[1,2])

topic-test中指定的分区1和分区2设置位移

4

=kafka_offset(A1,[2,13])

topic-test中分区0设置位移为2,分区1设置位移为13