@Override
  public void close() {
    Utils.shutDownExecutorService(scheduler, 5, TimeUnit.MINUTES);
  }
Get next set of change feed entries for the specified partition, after the {@code curFindToken}.
The number of entries is capped by maxEntriesSize.
This method creates a cache for change feed entries. If the {@code curFindToken} is not valid,
or if all the items in the cache are consumed, then it queries Cosmos for new entries.
@param curFindToken {@link FindToken} after which the next entries have to be returned.
@param maxTotalSizeOfEntries maximum size of all the blobs returned.
@param partitionPath Partition for which change feed entries have to be returned.
@return {@link FindResult} instance that contains updated {@link FindToken} object which can act as a bookmark for
subsequent requests, and {@link List} of {@link CloudBlobMetadata} entries.
@throws CosmosException if any cosmos query encounters error.
ambry-cloud/src/main/java/com/github/ambry/cloud/azure/CosmosChangeFeedBasedReplicationFeed.java