RdKafka\ConsumerTopic::consumeStop

(PECL rdkafka >= 0.9.1)

RdKafka\ConsumerTopic::consumeStop — Stop consuming messages from partition

Description

public RdKafka\ConsumerTopic::consumeStop ( integer $partition ) : void

Stop consuming messages for partition, purging all messages currently in the local queue.

Parameters

partition

Partition ID

Return Values

Returns no value.