diff --git a/README.md b/README.md
index decec8b..7a799b2 100644
--- a/README.md
+++ b/README.md
@@ -26,6 +26,7 @@ Functional examples are included in the
 | Name | Description | Type | Default | Required |
 |------|-------------|------|---------|:--------:|
 | data\_fusion\_service\_account | Google Managed Data Fusion Service Account Email | `any` | n/a | yes |
+| datafusion\_version | Data Fusion Version to deploy. | `string` | `null` | no |
 | dataproc\_subnet | Name for subnet to create and configure for Dataproc clusters controlled by private Data Fusion instance. | `string` | `"dataproc-subnet"` | no |
 | description | An optional description of the instance. | `string` | `null` | no |
 | labels | The resource labels for instance to use to annotate any related underlying resources, such as Compute Engine VMs. | `map(string)` | `{}` | no |
diff --git a/main.tf b/main.tf
index c34e531..bf11e80 100644
--- a/main.tf
+++ b/main.tf
@@ -35,6 +35,7 @@ module "instance" {
   region      = var.region
   type        = var.type
   labels      = var.labels
+  datafusion_version   = var.datafusion_version
   options     = var.options
   network_config = {
     network       = module.data_fusion_network.data_fusion_vpc.network_name
diff --git a/modules/instance/main.tf b/modules/instance/main.tf
index aada890..927d41d 100644
--- a/modules/instance/main.tf
+++ b/modules/instance/main.tf
@@ -24,6 +24,7 @@ resource "google_data_fusion_instance" "instance" {
   enable_stackdriver_logging    = true
   enable_stackdriver_monitoring = true
   labels                        = var.labels
+  version                       = var.datafusion_version
   options                       = var.options
   private_instance              = var.network_config != null
 
diff --git a/modules/instance/variables.tf b/modules/instance/variables.tf
index f627d7a..39f5a53 100644
--- a/modules/instance/variables.tf
+++ b/modules/instance/variables.tf
@@ -24,6 +24,12 @@ variable "project" {
   type        = string
 }
 
+variable "datafusion_version" {
+  description = "Data Fusion Version to deploy."
+  type        = string
+  default     = null
+}
+
 variable "description" {
   description = "An optional description of the instance."
   type        = string
diff --git a/variables.tf b/variables.tf
index 7c31e72..93ffbfc 100644
--- a/variables.tf
+++ b/variables.tf
@@ -24,6 +24,12 @@ variable "project" {
   type        = string
 }
 
+variable "datafusion_version" {
+  description = "Data Fusion Version to deploy."
+  type        = string
+  default     = null
+}
+
 variable "network" {
   description = "Name for VPC to create or reuse to be configured for use with private Data Fusion instance."
   type        = string