RdKafka\Conf::setOffsetCommitCb

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

RdKafka\Conf::setOffsetCommitCb — Set offset commit callback

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

Set offset commit callback for use with consumer groups

callback (callable)

A callable with the following signature:


<?php
/**
 * @param object $kafka
 * @param int $err
 * @param array $partitions
 */
function ($kafka, $err, $partitions);

Returns no value.