gcp.managedkafka.ConnectCluster

import * as pulumi from "@pulumi/pulumi";
import * as gcp from "@pulumi/gcp";
import * as time from "@pulumi/time";

const project = new gcp.organizations.Project("project", {
    projectId: "tf-test_91980",
    name: "tf-test_37118",
    orgId: "123456789",
    billingAccount: "000000-0000000-0000000-000000",
    deletionPolicy: "DELETE",
});
const wait60Seconds = new time.index.Sleep("wait_60_seconds", {createDuration: "60s"}, {
    dependsOn: [project],
});
const compute = new gcp.projects.Service("compute", {
    project: project.projectId,
    service: "compute.googleapis.com",
}, {
    dependsOn: [wait60Seconds],
});
const managedkafka = new gcp.projects.Service("managedkafka", {
    project: project.projectId,
    service: "managedkafka.googleapis.com",
}, {
    dependsOn: [compute],
});
const wait120Seconds = new time.index.Sleep("wait_120_seconds", {createDuration: "120s"}, {
    dependsOn: [managedkafka],
});
const mkcSecondarySubnet = new gcp.compute.Subnetwork("mkc_secondary_subnet", {
    project: project.projectId,
    name: "my-secondary-subnetwork",
    ipCidrRange: "10.3.0.0/16",
    region: "us-central1",
    network: "default",
}, {
    dependsOn: [wait120Seconds],
});
const gmkCluster = new gcp.managedkafka.Cluster("gmk_cluster", {
    project: project.projectId,
    clusterId: "my-cluster",
    location: "us-central1",
    capacityConfig: {
        vcpuCount: "3",
        memoryBytes: "3221225472",
    },
    gcpConfig: {
        accessConfig: {
            networkConfigs: [{
                subnet: pulumi.interpolate`projects/${project.projectId}/regions/us-central1/subnetworks/default`,
            }],
        },
    },
}, {
    dependsOn: [managedkafka],
});
const example = new gcp.managedkafka.ConnectCluster("example", {
    project: project.projectId,
    connectClusterId: "my-connect-cluster",
    kafkaCluster: pulumi.interpolate`projects/${project.projectId}/locations/us-central1/clusters/${gmkCluster.clusterId}`,
    location: "us-central1",
    capacityConfig: {
        vcpuCount: "12",
        memoryBytes: "21474836480",
    },
    gcpConfig: {
        accessConfig: {
            networkConfigs: [{
                primarySubnet: pulumi.interpolate`projects/${project.projectId}/regions/us-central1/subnetworks/default`,
                additionalSubnets: [mkcSecondarySubnet.id],
                dnsDomainNames: [pulumi.interpolate`${gmkCluster.clusterId}.us-central1.managedkafka.${project.projectId}.cloud.goog`],
            }],
        },
    },
    labels: {
        key: "value",
    },
}, {
    dependsOn: [managedkafka],
});

import pulumi
import pulumi_gcp as gcp
import pulumi_time as time

project = gcp.organizations.Project("project",
    project_id="tf-test_91980",
    name="tf-test_37118",
    org_id="123456789",
    billing_account="000000-0000000-0000000-000000",
    deletion_policy="DELETE")
wait60_seconds = time.index.Sleep("wait_60_seconds", create_duration=60s,
opts = pulumi.ResourceOptions(depends_on=[project]))
compute = gcp.projects.Service("compute",
    project=project.project_id,
    service="compute.googleapis.com",
    opts = pulumi.ResourceOptions(depends_on=[wait60_seconds]))
managedkafka = gcp.projects.Service("managedkafka",
    project=project.project_id,
    service="managedkafka.googleapis.com",
    opts = pulumi.ResourceOptions(depends_on=[compute]))
wait120_seconds = time.index.Sleep("wait_120_seconds", create_duration=120s,
opts = pulumi.ResourceOptions(depends_on=[managedkafka]))
mkc_secondary_subnet = gcp.compute.Subnetwork("mkc_secondary_subnet",
    project=project.project_id,
    name="my-secondary-subnetwork",
    ip_cidr_range="10.3.0.0/16",
    region="us-central1",
    network="default",
    opts = pulumi.ResourceOptions(depends_on=[wait120_seconds]))
gmk_cluster = gcp.managedkafka.Cluster("gmk_cluster",
    project=project.project_id,
    cluster_id="my-cluster",
    location="us-central1",
    capacity_config={
        "vcpu_count": "3",
        "memory_bytes": "3221225472",
    },
    gcp_config={
        "access_config": {
            "network_configs": [{
                "subnet": project.project_id.apply(lambda project_id: f"projects/{project_id}/regions/us-central1/subnetworks/default"),
            }],
        },
    },
    opts = pulumi.ResourceOptions(depends_on=[managedkafka]))
example = gcp.managedkafka.ConnectCluster("example",
    project=project.project_id,
    connect_cluster_id="my-connect-cluster",
    kafka_cluster=pulumi.Output.all(
        project_id=project.project_id,
        cluster_id=gmk_cluster.cluster_id
).apply(lambda resolved_outputs: f"projects/{resolved_outputs['project_id']}/locations/us-central1/clusters/{resolved_outputs['cluster_id']}")
,
    location="us-central1",
    capacity_config={
        "vcpu_count": "12",
        "memory_bytes": "21474836480",
    },
    gcp_config={
        "access_config": {
            "network_configs": [{
                "primary_subnet": project.project_id.apply(lambda project_id: f"projects/{project_id}/regions/us-central1/subnetworks/default"),
                "additional_subnets": [mkc_secondary_subnet.id],
                "dns_domain_names": [pulumi.Output.all(
                    cluster_id=gmk_cluster.cluster_id,
                    project_id=project.project_id
).apply(lambda resolved_outputs: f"{resolved_outputs['cluster_id']}.us-central1.managedkafka.{resolved_outputs['project_id']}.cloud.goog")
],
            }],
        },
    },
    labels={
        "key": "value",
    },
    opts = pulumi.ResourceOptions(depends_on=[managedkafka]))

package main

import (
	"fmt"

	"github.com/pulumi/pulumi-gcp/sdk/v8/go/gcp/compute"
	"github.com/pulumi/pulumi-gcp/sdk/v8/go/gcp/managedkafka"
	"github.com/pulumi/pulumi-gcp/sdk/v8/go/gcp/organizations"
	"github.com/pulumi/pulumi-gcp/sdk/v8/go/gcp/projects"
	"github.com/pulumi/pulumi-time/sdk/go/time"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		project, err := organizations.NewProject(ctx, "project", &organizations.ProjectArgs{
			ProjectId:      pulumi.String("tf-test_91980"),
			Name:           pulumi.String("tf-test_37118"),
			OrgId:          pulumi.String("123456789"),
			BillingAccount: pulumi.String("000000-0000000-0000000-000000"),
			DeletionPolicy: pulumi.String("DELETE"),
		})
		if err != nil {
			return err
		}
		wait60Seconds, err := time.NewSleep(ctx, "wait_60_seconds", &time.SleepArgs{
			CreateDuration: "60s",
		}, pulumi.DependsOn([]pulumi.Resource{
			project,
		}))
		if err != nil {
			return err
		}
		compute, err := projects.NewService(ctx, "compute", &projects.ServiceArgs{
			Project: project.ProjectId,
			Service: pulumi.String("compute.googleapis.com"),
		}, pulumi.DependsOn([]pulumi.Resource{
			wait60Seconds,
		}))
		if err != nil {
			return err
		}
		managedkafka, err := projects.NewService(ctx, "managedkafka", &projects.ServiceArgs{
			Project: project.ProjectId,
			Service: pulumi.String("managedkafka.googleapis.com"),
		}, pulumi.DependsOn([]pulumi.Resource{
			compute,
		}))
		if err != nil {
			return err
		}
		wait120Seconds, err := time.NewSleep(ctx, "wait_120_seconds", &time.SleepArgs{
			CreateDuration: "120s",
		}, pulumi.DependsOn([]pulumi.Resource{
			managedkafka,
		}))
		if err != nil {
			return err
		}
		mkcSecondarySubnet, err := compute.NewSubnetwork(ctx, "mkc_secondary_subnet", &compute.SubnetworkArgs{
			Project:     project.ProjectId,
			Name:        pulumi.String("my-secondary-subnetwork"),
			IpCidrRange: pulumi.String("10.3.0.0/16"),
			Region:      pulumi.String("us-central1"),
			Network:     pulumi.String("default"),
		}, pulumi.DependsOn([]pulumi.Resource{
			wait120Seconds,
		}))
		if err != nil {
			return err
		}
		gmkCluster, err := managedkafka.NewCluster(ctx, "gmk_cluster", &managedkafka.ClusterArgs{
			Project:   project.ProjectId,
			ClusterId: pulumi.String("my-cluster"),
			Location:  pulumi.String("us-central1"),
			CapacityConfig: &managedkafka.ClusterCapacityConfigArgs{
				VcpuCount:   pulumi.String("3"),
				MemoryBytes: pulumi.String("3221225472"),
			},
			GcpConfig: &managedkafka.ClusterGcpConfigArgs{
				AccessConfig: &managedkafka.ClusterGcpConfigAccessConfigArgs{
					NetworkConfigs: managedkafka.ClusterGcpConfigAccessConfigNetworkConfigArray{
						&managedkafka.ClusterGcpConfigAccessConfigNetworkConfigArgs{
							Subnet: project.ProjectId.ApplyT(func(projectId string) (string, error) {
								return fmt.Sprintf("projects/%v/regions/us-central1/subnetworks/default", projectId), nil
							}).(pulumi.StringOutput),
						},
					},
				},
			},
		}, pulumi.DependsOn([]pulumi.Resource{
			managedkafka,
		}))
		if err != nil {
			return err
		}
		_, err = managedkafka.NewConnectCluster(ctx, "example", &managedkafka.ConnectClusterArgs{
			Project:          project.ProjectId,
			ConnectClusterId: pulumi.String("my-connect-cluster"),
			KafkaCluster: pulumi.All(project.ProjectId, gmkCluster.ClusterId).ApplyT(func(_args []interface{}) (string, error) {
				projectId := _args[0].(string)
				clusterId := _args[1].(string)
				return fmt.Sprintf("projects/%v/locations/us-central1/clusters/%v", projectId, clusterId), nil
			}).(pulumi.StringOutput),
			Location: pulumi.String("us-central1"),
			CapacityConfig: &managedkafka.ConnectClusterCapacityConfigArgs{
				VcpuCount:   pulumi.String("12"),
				MemoryBytes: pulumi.String("21474836480"),
			},
			GcpConfig: &managedkafka.ConnectClusterGcpConfigArgs{
				AccessConfig: &managedkafka.ConnectClusterGcpConfigAccessConfigArgs{
					NetworkConfigs: managedkafka.ConnectClusterGcpConfigAccessConfigNetworkConfigArray{
						&managedkafka.ConnectClusterGcpConfigAccessConfigNetworkConfigArgs{
							PrimarySubnet: project.ProjectId.ApplyT(func(projectId string) (string, error) {
								return fmt.Sprintf("projects/%v/regions/us-central1/subnetworks/default", projectId), nil
							}).(pulumi.StringOutput),
							AdditionalSubnets: pulumi.StringArray{
								mkcSecondarySubnet.ID(),
							},
							DnsDomainNames: pulumi.StringArray{
								pulumi.All(gmkCluster.ClusterId, project.ProjectId).ApplyT(func(_args []interface{}) (string, error) {
									clusterId := _args[0].(string)
									projectId := _args[1].(string)
									return fmt.Sprintf("%v.us-central1.managedkafka.%v.cloud.goog", clusterId, projectId), nil
								}).(pulumi.StringOutput),
							},
						},
					},
				},
			},
			Labels: pulumi.StringMap{
				"key": pulumi.String("value"),
			},
		}, pulumi.DependsOn([]pulumi.Resource{
			managedkafka,
		}))
		if err != nil {
			return err
		}
		return nil
	})
}

using System.Collections.Generic;
using System.Linq;
using Pulumi;
using Gcp = Pulumi.Gcp;
using Time = Pulumi.Time;

return await Deployment.RunAsync(() => 
{
    var project = new Gcp.Organizations.Project("project", new()
    {
        ProjectId = "tf-test_91980",
        Name = "tf-test_37118",
        OrgId = "123456789",
        BillingAccount = "000000-0000000-0000000-000000",
        DeletionPolicy = "DELETE",
    });

    var wait60Seconds = new Time.Index.Sleep("wait_60_seconds", new()
    {
        CreateDuration = "60s",
    }, new CustomResourceOptions
    {
        DependsOn =
        {
            project,
        },
    });

    var compute = new Gcp.Projects.Service("compute", new()
    {
        Project = project.ProjectId,
        ServiceName = "compute.googleapis.com",
    }, new CustomResourceOptions
    {
        DependsOn =
        {
            wait60Seconds,
        },
    });

    var managedkafka = new Gcp.Projects.Service("managedkafka", new()
    {
        Project = project.ProjectId,
        ServiceName = "managedkafka.googleapis.com",
    }, new CustomResourceOptions
    {
        DependsOn =
        {
            compute,
        },
    });

    var wait120Seconds = new Time.Index.Sleep("wait_120_seconds", new()
    {
        CreateDuration = "120s",
    }, new CustomResourceOptions
    {
        DependsOn =
        {
            managedkafka,
        },
    });

    var mkcSecondarySubnet = new Gcp.Compute.Subnetwork("mkc_secondary_subnet", new()
    {
        Project = project.ProjectId,
        Name = "my-secondary-subnetwork",
        IpCidrRange = "10.3.0.0/16",
        Region = "us-central1",
        Network = "default",
    }, new CustomResourceOptions
    {
        DependsOn =
        {
            wait120Seconds,
        },
    });

    var gmkCluster = new Gcp.ManagedKafka.Cluster("gmk_cluster", new()
    {
        Project = project.ProjectId,
        ClusterId = "my-cluster",
        Location = "us-central1",
        CapacityConfig = new Gcp.ManagedKafka.Inputs.ClusterCapacityConfigArgs
        {
            VcpuCount = "3",
            MemoryBytes = "3221225472",
        },
        GcpConfig = new Gcp.ManagedKafka.Inputs.ClusterGcpConfigArgs
        {
            AccessConfig = new Gcp.ManagedKafka.Inputs.ClusterGcpConfigAccessConfigArgs
            {
                NetworkConfigs = new[]
                {
                    new Gcp.ManagedKafka.Inputs.ClusterGcpConfigAccessConfigNetworkConfigArgs
                    {
                        Subnet = project.ProjectId.Apply(projectId => $"projects/{projectId}/regions/us-central1/subnetworks/default"),
                    },
                },
            },
        },
    }, new CustomResourceOptions
    {
        DependsOn =
        {
            managedkafka,
        },
    });

    var example = new Gcp.ManagedKafka.ConnectCluster("example", new()
    {
        Project = project.ProjectId,
        ConnectClusterId = "my-connect-cluster",
        KafkaCluster = Output.Tuple(project.ProjectId, gmkCluster.ClusterId).Apply(values =>
        {
            var projectId = values.Item1;
            var clusterId = values.Item2;
            return $"projects/{projectId}/locations/us-central1/clusters/{clusterId}";
        }),
        Location = "us-central1",
        CapacityConfig = new Gcp.ManagedKafka.Inputs.ConnectClusterCapacityConfigArgs
        {
            VcpuCount = "12",
            MemoryBytes = "21474836480",
        },
        GcpConfig = new Gcp.ManagedKafka.Inputs.ConnectClusterGcpConfigArgs
        {
            AccessConfig = new Gcp.ManagedKafka.Inputs.ConnectClusterGcpConfigAccessConfigArgs
            {
                NetworkConfigs = new[]
                {
                    new Gcp.ManagedKafka.Inputs.ConnectClusterGcpConfigAccessConfigNetworkConfigArgs
                    {
                        PrimarySubnet = project.ProjectId.Apply(projectId => $"projects/{projectId}/regions/us-central1/subnetworks/default"),
                        AdditionalSubnets = new[]
                        {
                            mkcSecondarySubnet.Id,
                        },
                        DnsDomainNames = new[]
                        {
                            Output.Tuple(gmkCluster.ClusterId, project.ProjectId).Apply(values =>
                            {
                                var clusterId = values.Item1;
                                var projectId = values.Item2;
                                return $"{clusterId}.us-central1.managedkafka.{projectId}.cloud.goog";
                            }),
                        },
                    },
                },
            },
        },
        Labels = 
        {
            { "key", "value" },
        },
    }, new CustomResourceOptions
    {
        DependsOn =
        {
            managedkafka,
        },
    });

});

package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.gcp.organizations.Project;
import com.pulumi.gcp.organizations.ProjectArgs;
import com.pulumi.time.sleep;
import com.pulumi.time.sleepArgs;
import com.pulumi.gcp.projects.Service;
import com.pulumi.gcp.projects.ServiceArgs;
import com.pulumi.gcp.compute.Subnetwork;
import com.pulumi.gcp.compute.SubnetworkArgs;
import com.pulumi.gcp.managedkafka.Cluster;
import com.pulumi.gcp.managedkafka.ClusterArgs;
import com.pulumi.gcp.managedkafka.inputs.ClusterCapacityConfigArgs;
import com.pulumi.gcp.managedkafka.inputs.ClusterGcpConfigArgs;
import com.pulumi.gcp.managedkafka.inputs.ClusterGcpConfigAccessConfigArgs;
import com.pulumi.gcp.managedkafka.ConnectCluster;
import com.pulumi.gcp.managedkafka.ConnectClusterArgs;
import com.pulumi.gcp.managedkafka.inputs.ConnectClusterCapacityConfigArgs;
import com.pulumi.gcp.managedkafka.inputs.ConnectClusterGcpConfigArgs;
import com.pulumi.gcp.managedkafka.inputs.ConnectClusterGcpConfigAccessConfigArgs;
import com.pulumi.resources.CustomResourceOptions;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;

public class App {
    public static void main(String[] args) {
        Pulumi.run(App::stack);
    }

    public static void stack(Context ctx) {
        var project = new Project("project", ProjectArgs.builder()
            .projectId("tf-test_91980")
            .name("tf-test_37118")
            .orgId("123456789")
            .billingAccount("000000-0000000-0000000-000000")
            .deletionPolicy("DELETE")
            .build());

        var wait60Seconds = new Sleep("wait60Seconds", SleepArgs.builder()
            .createDuration("60s")
            .build(), CustomResourceOptions.builder()
                .dependsOn(List.of(project))
                .build());

        var compute = new Service("compute", ServiceArgs.builder()
            .project(project.projectId())
            .service("compute.googleapis.com")
            .build(), CustomResourceOptions.builder()
                .dependsOn(wait60Seconds)
                .build());

        var managedkafka = new Service("managedkafka", ServiceArgs.builder()
            .project(project.projectId())
            .service("managedkafka.googleapis.com")
            .build(), CustomResourceOptions.builder()
                .dependsOn(compute)
                .build());

        var wait120Seconds = new Sleep("wait120Seconds", SleepArgs.builder()
            .createDuration("120s")
            .build(), CustomResourceOptions.builder()
                .dependsOn(List.of(managedkafka))
                .build());

        var mkcSecondarySubnet = new Subnetwork("mkcSecondarySubnet", SubnetworkArgs.builder()
            .project(project.projectId())
            .name("my-secondary-subnetwork")
            .ipCidrRange("10.3.0.0/16")
            .region("us-central1")
            .network("default")
            .build(), CustomResourceOptions.builder()
                .dependsOn(wait120Seconds)
                .build());

        var gmkCluster = new Cluster("gmkCluster", ClusterArgs.builder()
            .project(project.projectId())
            .clusterId("my-cluster")
            .location("us-central1")
            .capacityConfig(ClusterCapacityConfigArgs.builder()
                .vcpuCount("3")
                .memoryBytes("3221225472")
                .build())
            .gcpConfig(ClusterGcpConfigArgs.builder()
                .accessConfig(ClusterGcpConfigAccessConfigArgs.builder()
                    .networkConfigs(ClusterGcpConfigAccessConfigNetworkConfigArgs.builder()
                        .subnet(project.projectId().applyValue(_projectId -> String.format("projects/%s/regions/us-central1/subnetworks/default", _projectId)))
                        .build())
                    .build())
                .build())
            .build(), CustomResourceOptions.builder()
                .dependsOn(managedkafka)
                .build());

        var example = new ConnectCluster("example", ConnectClusterArgs.builder()
            .project(project.projectId())
            .connectClusterId("my-connect-cluster")
            .kafkaCluster(Output.tuple(project.projectId(), gmkCluster.clusterId()).applyValue(values -> {
                var projectId = values.t1;
                var clusterId = values.t2;
                return String.format("projects/%s/locations/us-central1/clusters/%s", projectId,clusterId);
            }))
            .location("us-central1")
            .capacityConfig(ConnectClusterCapacityConfigArgs.builder()
                .vcpuCount("12")
                .memoryBytes("21474836480")
                .build())
            .gcpConfig(ConnectClusterGcpConfigArgs.builder()
                .accessConfig(ConnectClusterGcpConfigAccessConfigArgs.builder()
                    .networkConfigs(ConnectClusterGcpConfigAccessConfigNetworkConfigArgs.builder()
                        .primarySubnet(project.projectId().applyValue(_projectId -> String.format("projects/%s/regions/us-central1/subnetworks/default", _projectId)))
                        .additionalSubnets(mkcSecondarySubnet.id())
                        .dnsDomainNames(Output.tuple(gmkCluster.clusterId(), project.projectId()).applyValue(values -> {
                            var clusterId = values.t1;
                            var projectId = values.t2;
                            return String.format("%s.us-central1.managedkafka.%s.cloud.goog", clusterId,projectId);
                        }))
                        .build())
                    .build())
                .build())
            .labels(Map.of("key", "value"))
            .build(), CustomResourceOptions.builder()
                .dependsOn(managedkafka)
                .build());

    }
}

resources:
  project:
    type: gcp:organizations:Project
    properties:
      projectId: tf-test_91980
      name: tf-test_37118
      orgId: '123456789'
      billingAccount: 000000-0000000-0000000-000000
      deletionPolicy: DELETE
  wait60Seconds:
    type: time:sleep
    name: wait_60_seconds
    properties:
      createDuration: 60s
    options:
      dependsOn:
        - ${project}
  compute:
    type: gcp:projects:Service
    properties:
      project: ${project.projectId}
      service: compute.googleapis.com
    options:
      dependsOn:
        - ${wait60Seconds}
  managedkafka:
    type: gcp:projects:Service
    properties:
      project: ${project.projectId}
      service: managedkafka.googleapis.com
    options:
      dependsOn:
        - ${compute}
  wait120Seconds:
    type: time:sleep
    name: wait_120_seconds
    properties:
      createDuration: 120s
    options:
      dependsOn:
        - ${managedkafka}
  mkcSecondarySubnet:
    type: gcp:compute:Subnetwork
    name: mkc_secondary_subnet
    properties:
      project: ${project.projectId}
      name: my-secondary-subnetwork
      ipCidrRange: 10.3.0.0/16
      region: us-central1
      network: default
    options:
      dependsOn:
        - ${wait120Seconds}
  gmkCluster:
    type: gcp:managedkafka:Cluster
    name: gmk_cluster
    properties:
      project: ${project.projectId}
      clusterId: my-cluster
      location: us-central1
      capacityConfig:
        vcpuCount: 3
        memoryBytes: 3.221225472e+09
      gcpConfig:
        accessConfig:
          networkConfigs:
            - subnet: projects/${project.projectId}/regions/us-central1/subnetworks/default
    options:
      dependsOn:
        - ${managedkafka}
  example:
    type: gcp:managedkafka:ConnectCluster
    properties:
      project: ${project.projectId}
      connectClusterId: my-connect-cluster
      kafkaCluster: projects/${project.projectId}/locations/us-central1/clusters/${gmkCluster.clusterId}
      location: us-central1
      capacityConfig:
        vcpuCount: 12
        memoryBytes: 2.147483648e+10
      gcpConfig:
        accessConfig:
          networkConfigs:
            - primarySubnet: projects/${project.projectId}/regions/us-central1/subnetworks/default
              additionalSubnets:
                - ${mkcSecondarySubnet.id}
              dnsDomainNames:
                - ${gmkCluster.clusterId}.us-central1.managedkafka.${project.projectId}.cloud.goog
      labels:
        key: value
    options:
      dependsOn:
        - ${managedkafka}

var connectClusterResource = new Gcp.ManagedKafka.ConnectCluster("connectClusterResource", new()
{
    CapacityConfig = new Gcp.ManagedKafka.Inputs.ConnectClusterCapacityConfigArgs
    {
        MemoryBytes = "string",
        VcpuCount = "string",
    },
    ConnectClusterId = "string",
    GcpConfig = new Gcp.ManagedKafka.Inputs.ConnectClusterGcpConfigArgs
    {
        AccessConfig = new Gcp.ManagedKafka.Inputs.ConnectClusterGcpConfigAccessConfigArgs
        {
            NetworkConfigs = new[]
            {
                new Gcp.ManagedKafka.Inputs.ConnectClusterGcpConfigAccessConfigNetworkConfigArgs
                {
                    PrimarySubnet = "string",
                    AdditionalSubnets = new[]
                    {
                        "string",
                    },
                    DnsDomainNames = new[]
                    {
                        "string",
                    },
                },
            },
        },
    },
    KafkaCluster = "string",
    Location = "string",
    Labels = 
    {
        { "string", "string" },
    },
    Project = "string",
});

example, err := managedkafka.NewConnectCluster(ctx, "connectClusterResource", &managedkafka.ConnectClusterArgs{
	CapacityConfig: &managedkafka.ConnectClusterCapacityConfigArgs{
		MemoryBytes: pulumi.String("string"),
		VcpuCount:   pulumi.String("string"),
	},
	ConnectClusterId: pulumi.String("string"),
	GcpConfig: &managedkafka.ConnectClusterGcpConfigArgs{
		AccessConfig: &managedkafka.ConnectClusterGcpConfigAccessConfigArgs{
			NetworkConfigs: managedkafka.ConnectClusterGcpConfigAccessConfigNetworkConfigArray{
				&managedkafka.ConnectClusterGcpConfigAccessConfigNetworkConfigArgs{
					PrimarySubnet: pulumi.String("string"),
					AdditionalSubnets: pulumi.StringArray{
						pulumi.String("string"),
					},
					DnsDomainNames: pulumi.StringArray{
						pulumi.String("string"),
					},
				},
			},
		},
	},
	KafkaCluster: pulumi.String("string"),
	Location:     pulumi.String("string"),
	Labels: pulumi.StringMap{
		"string": pulumi.String("string"),
	},
	Project: pulumi.String("string"),
})

var connectClusterResource = new ConnectCluster("connectClusterResource", ConnectClusterArgs.builder()
    .capacityConfig(ConnectClusterCapacityConfigArgs.builder()
        .memoryBytes("string")
        .vcpuCount("string")
        .build())
    .connectClusterId("string")
    .gcpConfig(ConnectClusterGcpConfigArgs.builder()
        .accessConfig(ConnectClusterGcpConfigAccessConfigArgs.builder()
            .networkConfigs(ConnectClusterGcpConfigAccessConfigNetworkConfigArgs.builder()
                .primarySubnet("string")
                .additionalSubnets("string")
                .dnsDomainNames("string")
                .build())
            .build())
        .build())
    .kafkaCluster("string")
    .location("string")
    .labels(Map.of("string", "string"))
    .project("string")
    .build());

connect_cluster_resource = gcp.managedkafka.ConnectCluster("connectClusterResource",
    capacity_config={
        "memory_bytes": "string",
        "vcpu_count": "string",
    },
    connect_cluster_id="string",
    gcp_config={
        "access_config": {
            "network_configs": [{
                "primary_subnet": "string",
                "additional_subnets": ["string"],
                "dns_domain_names": ["string"],
            }],
        },
    },
    kafka_cluster="string",
    location="string",
    labels={
        "string": "string",
    },
    project="string")

const connectClusterResource = new gcp.managedkafka.ConnectCluster("connectClusterResource", {
    capacityConfig: {
        memoryBytes: "string",
        vcpuCount: "string",
    },
    connectClusterId: "string",
    gcpConfig: {
        accessConfig: {
            networkConfigs: [{
                primarySubnet: "string",
                additionalSubnets: ["string"],
                dnsDomainNames: ["string"],
            }],
        },
    },
    kafkaCluster: "string",
    location: "string",
    labels: {
        string: "string",
    },
    project: "string",
});

type: gcp:managedkafka:ConnectCluster
properties:
    capacityConfig:
        memoryBytes: string
        vcpuCount: string
    connectClusterId: string
    gcpConfig:
        accessConfig:
            networkConfigs:
                - additionalSubnets:
                    - string
                  dnsDomainNames:
                    - string
                  primarySubnet: string
    kafkaCluster: string
    labels:
        string: string
    location: string
    project: string