(PECL rdkafka >= 0.9.1)
RdKafka\ConsumerTopic::consume — Consume a single message from a partition
Consume a single message from
Consumer must have been previously started with RdKafka\ConsumerTopic::consumeStart().
The returned message's
errproperty must be checked for errors.
errproperty being equal to
RD_KAFKA_RESP_ERR__PARTITION_EOFsignals that the end of the partition has been reached, which should typically not be considered an error. The application should handle this case (e.g., ignore).
The partition to consume
The maximum amount of time to wait for a message to be received.
Returns a RdKafka\Message or
NULL on timeout.