docs: protected void invoke(String serviceName, Operation operation, int partitionId) {
          try {
              operationCount++;
              operationService
                      .invokeOnPartition(serviceName, operation, partitionId)
                      .andThen(mergeCallback);
          } catch (Throwable t) {
              throw rethrow(t);
          }
      }