(PECL rdkafka >= 0.9.1)
RdKafka\Queue::consume — Consume a single message
$timeout_ms
) : RdKafka\MessageConsume a single message. See RdKafka\ConsumerTopic::consume().
timeout_ms
The maximum amount of time to wait for a message to be received.
Returns a RdKafka\Message or NULL
on timeout.