Documentation of php-simple-kafka-client
Edit this page

getCommittedOffsets

Description

public function getCommittedOffsets(array $topics, int $timeoutMs): array {}

Returns the committed offsets for topics and partitions for a consumer group

Example

$conf = SimpleKafkaClient\Configuration();
$conf->set('metadata.broker.list', 'kafka:9092');
$consumer = new SimpleKafkaClient\Consumer($conf);
$topicPartition = new TopicPartition('test-topic', 0);
var_dump($consumer->getCommittedOffsets([$topicPartition], 10000));