(PECL rdkafka >= 4.0.0)
RdKafka\ConsumerTopic::consumeBatch — Consume a batch of messages from a partition
$batch_size) : array
Consume a batch of messages from
Consumer must have been previously started with RdKafka\ConsumerTopic::consumeStart().
The partition to consume
The maximum amount of time to wait for a batch to be received.
The batch size of messages to be returned.
Returns an array of RdKafka\Message or
NULL on timeout.