code: @Override
      public String replayAsync(String apiKey, String subscription) {
          return replayAsyncSince(apiKey, subscription, null);
      }
docs: Any server can initiate a replay request, no need for @PartitionKey