formatting

Author: gAmUssA

terraform/README.adoc

@@ -18,7 +18,8 @@ export CONFLUENT_CLOUD_API_SECRET<API SECRET>
 
 == Execute Terraform Manifests
 
-The terraform manifests require the Confluent Cloud organization ID in order to provision infrastructure. This can be found in the Confluent Cloud console in the "Organization Settings" and exported to an environment variable:
+The terraform manifests require the Confluent Cloud organization ID in order to provision infrastructure. 
+This can be found in the Confluent Cloud console in the "Organization Settings" and exported to an environment variable:
 
 ```bash
 export TF_VAR_org_id=<ORG ID VALUE FROM CONSOLE>
@@ -42,7 +43,8 @@ Once completed, verify the infrastructure is created in the Confluent Cloud cons
 
 == Using Infrastructure in the Workshop
 
-In the Table API exercises, we'll need API keys and secrets to connect Flink to Confluent Cloud. This `terraform output` command will create a file with those parameters:
+In the Table API exercises, we will need API keys and secrets to connect Flink to Confluent Cloud. 
+This `terraform output` command will create a file with those parameters:
 
 ```bash
 terraform output -json \

terraform/flink-compute.tf

@@ -1,18 +1,16 @@
-
-
 resource "confluent_flink_compute_pool" "main_flink_pool" {
-  display_name     = "main_flink_pool"
-  cloud            = var.cloud_provider
-  region           = var.cloud_region
-  max_cfu          = 5
+  display_name = "main_flink_pool"
+  cloud        = var.cloud_provider
+  region       = var.cloud_region
+  max_cfu      = 5
   environment {
     id = confluent_environment.cc_env.id
   }
 }
 
 data "confluent_flink_region" "main_flink_region" {
-  cloud            = var.cloud_provider
-  region           = var.cloud_region
+  cloud  = var.cloud_provider
+  region = var.cloud_region
 }
 
 resource "confluent_service_account" "flink_developer" {
@@ -25,23 +23,23 @@ resource "confluent_role_binding" "fd_flink_developer" {
   role_name   = "FlinkDeveloper"
   crn_pattern = confluent_environment.cc_env.resource_name
 
-  depends_on = [ confluent_flink_compute_pool.main_flink_pool]
+  depends_on = [confluent_flink_compute_pool.main_flink_pool]
 }
 
 resource "confluent_role_binding" "fd_kafka_write" {
   principal   = "User:${confluent_service_account.flink_developer.id}"
   role_name   = "DeveloperWrite"
   crn_pattern = "${confluent_kafka_cluster.kafka_cluster.rbac_crn}/kafka=${confluent_kafka_cluster.kafka_cluster.id}/topic=*"
 
-  depends_on = [ confluent_kafka_cluster.kafka_cluster]
+  depends_on = [confluent_kafka_cluster.kafka_cluster]
 }
 
 resource "confluent_role_binding" "fd_kafka_read" {
   principal   = "User:${confluent_service_account.flink_developer.id}"
   role_name   = "DeveloperRead"
   crn_pattern = "${confluent_kafka_cluster.kafka_cluster.rbac_crn}/kafka=${confluent_kafka_cluster.kafka_cluster.id}/topic=*"
 
-  depends_on = [ confluent_kafka_cluster.kafka_cluster]
+  depends_on = [confluent_kafka_cluster.kafka_cluster]
 }
 
 resource "confluent_role_binding" "fd_schema_registry_write" {

terraform/output.tf

@@ -7,45 +7,45 @@ output "kafka_boostrap_servers" {
 }
 
 output "cloud" {
-    value = var.cloud_provider
+  value = var.cloud_provider
 }
 
 output "region" {
-    value = var.cloud_region
+  value = var.cloud_region
 }
 
 output "organization-id" {
-    value = replace(var.org_id, "\"", "")
+  value = replace(var.org_id, "\"", "")
 }
 
 output "environment-id" {
-    value = confluent_environment.cc_env.id
+  value = confluent_environment.cc_env.id
 }
 
 output "compute-pool-id" {
-    value = confluent_flink_compute_pool.main_flink_pool.id
+  value = confluent_flink_compute_pool.main_flink_pool.id
 }
 
 output "kafka_sasl_jaas_config" {
-    value = "org.apache.kafka.common.security.plain.PlainLoginModule required username='${confluent_api_key.kafka_developer_kafka_api_key.id}' password='${nonsensitive(confluent_api_key.kafka_developer_kafka_api_key.secret)}';"
+  value = "org.apache.kafka.common.security.plain.PlainLoginModule required username='${confluent_api_key.kafka_developer_kafka_api_key.id}' password='${nonsensitive(confluent_api_key.kafka_developer_kafka_api_key.secret)}';"
 }
 
 output "registry_url" {
-    value = data.confluent_schema_registry_cluster.advanced.rest_endpoint
+  value = data.confluent_schema_registry_cluster.advanced.rest_endpoint
 }
 
 output "registry_key" {
-    value = confluent_api_key.sr_manager_kafka_api_key.id
+  value = confluent_api_key.sr_manager_kafka_api_key.id
 }
 
 output "registry_secret" {
-    value = nonsensitive(confluent_api_key.sr_manager_kafka_api_key.secret)
+  value = nonsensitive(confluent_api_key.sr_manager_kafka_api_key.secret)
 }
 
 output "flink-api-key" {
-    value = confluent_api_key.flink_developer_api_key.id
+  value = confluent_api_key.flink_developer_api_key.id
 }
 
 output "flink-api-secret" {
-    value = nonsensitive(confluent_api_key.flink_developer_api_key.secret)
+  value = nonsensitive(confluent_api_key.flink_developer_api_key.secret)
 }

terraform/schema-registry.tf

@@ -19,7 +19,7 @@ resource "confluent_role_binding" "sr_manager_data_steward" {
   role_name   = "DataSteward"
   crn_pattern = confluent_environment.cc_env.resource_name
 
-  depends_on = [ data.confluent_schema_registry_cluster.advanced ]
+  depends_on = [data.confluent_schema_registry_cluster.advanced]
 }
 
 resource "confluent_api_key" "sr_manager_kafka_api_key" {

terraform/variables.tf

@@ -1,34 +1,34 @@
 variable "org_id" {
-  type = string
+  type        = string
   description = "CC Organization ID"
 }
 
 variable "cloud_provider" {
-  type = string
+  type        = string
   description = "cloud provider for Confluent Cloud"
-  default = "AWS"
+  default     = "AWS"
 }
 
 variable "cloud_region" {
-  type = string
+  type        = string
   description = "cloud provider region"
-  default = "us-east-2"
+  default     = "us-east-2"
 }
 
 variable "cc_env_name" {
-    type = string
-    description = "CC Environment Name"
-    default = "java_flink_workshop"
+  type        = string
+  description = "CC Environment Name"
+  default     = "java_flink_workshop"
 }
 
 variable "cc_default_kafka_cluster_name" {
-    type = string
-    description = "Kafka Default Cluster Name"
-    default = "workshop"
+  type        = string
+  description = "Kafka Default Cluster Name"
+  default     = "workshop"
 }
 
 variable "cc_default_flink_compute_pool_name" {
-    type = string
-    description = "Default Flink Compute Pool Name"
-    default = "flink-compute-pool"
+  type        = string
+  description = "Default Flink Compute Pool Name"
+  default     = "flink-compute-pool"
 }