offsetsForTimes
public function offsetsForTimes(array $topicPartitions, int $timeoutMs): array {}
Look up the offsets for the given partitions by timestamp.
The returned offset for each partition is the earliest offset whose
timestamp is greater than or equal to the given timestamp in the
corresponding partition.
$conf = SimpleKafkaClient\Configuration();
$conf->set('metadata.broker.list', 'kafka:9092');
$producer = new SimpleKafkaClient\Producer($conf);
$topicPartition = new TopicPartition('test-topic', 0, strtotime("-1 week"));
$offsetsOneWeekAgo = $producer->offsetForTimes([$topicPartition], 10000);