(PECL rdkafka >= 1.0.0, librdkafka >= 0.9)
RdKafka\KafkaConsumer::commit — Commit offsets
NULL] ) : void
Commit offsets synchronously, block until offsets are committed or the commit fails.
If a commit_cb callback is registered it will be called with commit details on a future call to consume.
Example #1 RdKafka\KafkaConsumer::commit() example
// Commit offsets for the current assignment
// Commit offsets based on the message's topic, partition, and offset
// Commit offsets by providing a list of TopicPartition
new RdKafka\TopicPartition($topic, $partition, $offset),