docs: Add MKC Samples for Creating Connectors

managedkafka/managedkafka_create_connect_cluster/main.tf

@@ -0,0 +1,59 @@
+/**
+ * Copyright 2025 Google LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+# [START managedkafka_create_connect_cluster_parent]
+resource "google_managed_kafka_cluster" "default" {
+  project    = data.google_project.default.project_id
+  cluster_id = "my-cluster-id"
+  location   = "us-central1"
+  capacity_config {
+    vcpu_count   = 3
+    memory_bytes = 3221225472 # 3 GiB
+  }
+  gcp_config {
+    access_config {
+      network_configs {
+        subnet = "projects/${data.google_project.default.number}/regions/us-central1/subnetworks/default"
+      }
+    }
+  }
+}
+
+# [START managedkafka_create_connect_cluster]
+resource "google_managed_kafka_connect_cluster" "default" {
+  provider           = google-beta
+  project            = data.google_project.default.project_id
+  connect_cluster_id = "my-connect-cluster-id"
+  location           = "us-central1"
+  kafka_cluster      = google_managed_kafka_cluster.default.id
+  capacity_config {
+    vcpu_count   = 12
+    memory_bytes = 12884901888 # 12 GiB
+  }
+  gcp_config {
+    access_config {
+      network_configs {
+        primary_subnet = "projects/${data.google_project.default.number}/regions/us-central1/subnetworks/default"
+      }
+    }
+  }
+}
+# [END managedkafka_create_connect_cluster]
+
+data "google_project" "default" {
+  provider = google-beta
+}
+# [END managedkafka_create_connect_cluster_parent]

managedkafka/managedkafka_create_connector_bigquery_sink/main.tf

@@ -0,0 +1,115 @@
+/**
+ * Copyright 2025 Google LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+# [START managedkafka_create_connector_bigquery_sink_parent]
+
+resource "google_managed_kafka_cluster" "default" {
+  project    = data.google_project.default.project_id
+  cluster_id = "my-cluster-id"
+  location   = "us-central1"
+  capacity_config {
+    vcpu_count   = 3
+    memory_bytes = 3221225472 # 3 GiB
+  }
+  gcp_config {
+    access_config {
+      network_configs {
+        subnet = google_compute_subnetwork.default.id
+      }
+    }
+  }
+}
+
+resource "google_managed_kafka_connect_cluster" "default" {
+  provider           = google-beta
+  project            = data.google_project.default.project_id
+  connect_cluster_id = "my-connect-cluster-id"
+  location           = "us-central1"
+  kafka_cluster      = google_managed_kafka_cluster.default.id
+  capacity_config {
+    vcpu_count   = 12
+    memory_bytes = 12884901888 # 12 GiB
+  }
+  gcp_config {
+    access_config {
+      network_configs {
+        primary_subnet = google_compute_subnetwork.default.id
+      }
+    }
+  }
+}
+
+# [START managedkafka_subnetwork]
+resource "google_compute_subnetwork" "default" {
+  name          = "test-subnetwork"
+  ip_cidr_range = "10.2.0.0/16"
+  region        = "us-central1"
+  network       = google_compute_network.default.id
+
+  provisioner "local-exec" {
+    when        = destroy
+    command     = <<-EOT
+      set -e
+      gcloud compute network-attachments list \
+        --filter="subnetworks:https://www.googleapis.com/compute/v1/${self.id}" \
+        --format="value(name)" --project="${self.project}" |
+        while read -r na_name; do
+          [[ -z "$na_name" ]] && continue
+          for i in {1..5}; do
+            gcloud compute network-attachments delete "$na_name" \
+              --project="${self.project}" --region="${self.region}" --quiet && break
+            if [[ $i -eq 5 ]]; then exit 1; fi
+            sleep 30
+          done
+        done
+    EOT
+    interpreter = ["bash", "-c"]
+  }
+}
+
+resource "google_compute_network" "default" {
+  name                    = "test-network"
+  auto_create_subnetworks = false
+}
+# [END managedkafka_subnetwork]
+
+# [START managedkafka_create_connector_bigquery_sink]
+resource "google_managed_kafka_connector" "example-bigquery-sink-connector" {
+  project         = data.google_project.default.project_id
+  connector_id    = "my-bigquery-sink-connector"
+  connect_cluster = google_managed_kafka_connect_cluster.default.connect_cluster_id
+  location        = "us-central1"
+
+  configs = {
+    "name"                           = "my-bigquery-sink-connector"
+    "project"                        = "GCP_PROJECT_ID"
+    "topics"                         = "GMK_TOPIC_ID"
+    "tasks.max"                      = "3"
+    "connector.class"                = "com.wepay.kafka.connect.bigquery.BigQuerySinkConnector"
+    "key.converter"                  = "org.apache.kafka.connect.storage.StringConverter"
+    "value.converter"                = "org.apache.kafka.connect.json.JsonConverter"
+    "value.converter.schemas.enable" = "false"
+    "defaultDataset"                 = "BQ_DATASET_ID"
+  }
+
+  provider = google-beta
+}
+# [END managedkafka_create_connector_bigquery_sink]
+
+data "google_project" "default" {
+}
+
+# [END managedkafka_create_connector_bigquery_sink_parent]

managedkafka/managedkafka_create_connector_cloud_storage_sink/main.tf

@@ -0,0 +1,115 @@
+/**
+ * Copyright 2025 Google LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+# [START managedkafka_create_connector_pubsub_source_parent]
+
+resource "google_managed_kafka_cluster" "default" {
+  project    = data.google_project.default.project_id
+  cluster_id = "my-cluster-id"
+  location   = "us-central1"
+  capacity_config {
+    vcpu_count   = 3
+    memory_bytes = 3221225472 # 3 GiB
+  }
+  gcp_config {
+    access_config {
+      network_configs {
+        subnet = google_compute_subnetwork.default.id
+      }
+    }
+  }
+}
+
+resource "google_managed_kafka_connect_cluster" "default" {
+  provider           = google-beta
+  project            = data.google_project.default.project_id
+  connect_cluster_id = "my-connect-cluster-id"
+  location           = "us-central1"
+  kafka_cluster      = google_managed_kafka_cluster.default.id
+  capacity_config {
+    vcpu_count   = 12
+    memory_bytes = 12884901888 # 12 GiB
+  }
+  gcp_config {
+    access_config {
+      network_configs {
+        primary_subnet = google_compute_subnetwork.default.id
+      }
+    }
+  }
+}
+
+# [START managedkafka_subnetwork]
+resource "google_compute_subnetwork" "default" {
+  name          = "test-subnetwork"
+  ip_cidr_range = "10.2.0.0/16"
+  region        = "us-central1"
+  network       = google_compute_network.default.id
+
+  provisioner "local-exec" {
+    when        = destroy
+    command     = <<-EOT
+      set -e
+      gcloud compute network-attachments list \
+        --filter="subnetworks:https://www.googleapis.com/compute/v1/${self.id}" \
+        --format="value(name)" --project="${self.project}" |
+        while read -r na_name; do
+          [[ -z "$na_name" ]] && continue
+          for i in {1..5}; do
+            gcloud compute network-attachments delete "$na_name" \
+              --project="${self.project}" --region="${self.region}" --quiet && break
+            if [[ $i -eq 5 ]]; then exit 1; fi
+            sleep 30
+          done
+        done
+    EOT
+    interpreter = ["bash", "-c"]
+  }
+}
+
+resource "google_compute_network" "default" {
+  name                    = "test-network"
+  auto_create_subnetworks = false
+}
+# [END managedkafka_subnetwork]
+
+# [START managedkafka_create_connector_cloud_storage_sink]
+resource "google_managed_kafka_connector" "example-cloud-storage-sink-connector" {
+  project         = data.google_project.default.project_id
+  connector_id    = "my-gcs-sink-connector"
+  connect_cluster = google_managed_kafka_connect_cluster.default.connect_cluster_id
+  location        = "us-central1"
+
+  configs = {
+    "connector.class"                = "io.aiven.kafka.connect.gcs.GcsSinkConnector"
+    "tasks.max"                      = "1"
+    "topics"                         = "GMK_TOPIC_ID"
+    "gcs.bucket.name"                = "GCS_BUCKET_NAME"
+    "gcs.credentials.default"        = "true"
+    "format.output.type"             = "json"
+    "name"                           = "my-gcs-sink-connector"
+    "value.converter"                = "org.apache.kafka.connect.json.JsonConverter"
+    "value.converter.schemas.enable" = "false"
+    "key.converter"                  = "org.apache.kafka.connect.storage.StringConverter"
+  }
+  provider = google-beta
+}
+# [END managedkafka_create_connector_cloud_storage_sink]
+
+data "google_project" "default" {
+}
+
+# [END managedkafka_create_connector_pubsub_source_parent]