RdKafka\KafkaConsumerTopic::offsetStore

(PECL rdkafka >= 1.0.0, librdkafka >= 0.9)

RdKafka\KafkaConsumerTopic::offsetStore — Store offset

Description

public RdKafka\KafkaConsumerTopic::offsetStore ( integer $partition , integer $offset ) : void

Store offset offset for topic partition partition. The offset will be commited (written) to the offset store according to auto.commit.interval.ms.

Note:

enable.auto.offset.store must be set to false when using this API.

Parameters

partition (integer)

Partition ID

offset (integer)

Offset

Return Values

Returns no value.