topics=[
                    fetch.TopicRequest(name=topic, partitions=[
                        fetch.PartitionRequest(
                            partition_id=partition_id,
                            offset=self.offsets[topic][partition_id],