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.