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.