RdKafka\Conf::setConsumeCb

(PECL rdkafka >= 3.1.0, librdkafka >= 0.9)

RdKafka\Conf::setConsumeCb — Set consume callback

Description

public RdKafka\Conf::setConsumeCb ( callable $callback ) : void

Set consume callback to use with poll

Parameters

callback (callable)

A callable with the following signature:

<?php
/**
 * @param Message $msg
 */
function ($msg);