1. Packages
  2. Packages
  3. Confluent Provider
  4. API Docs
  5. getKafkaCluster
Viewing docs for Confluent v0.1.0 (Older version)
published on Monday, Mar 9, 2026 by Pulumi
Go to latest version
Schema (JSON)
pulumi/pulumi-confluentcloud

confluentcloud.getKafkaCluster

confluentcloud logo
Viewing docs for Confluent v0.1.0 (Older version)
published on Monday, Mar 9, 2026 by Pulumi
Go to latest version
Schema (JSON)
pulumi/pulumi-confluentcloud

    confluentcloud.KafkaCluster describes a Kafka cluster data source.

    Example Usage

    using Pulumi;
using ConfluentCloud = Pulumi.ConfluentCloud;

class MyStack : Stack
{
    public MyStack()
    {
        var exampleUsingId = Output.Create(ConfluentCloud.GetKafkaCluster.InvokeAsync(new ConfluentCloud.GetKafkaClusterArgs
        {
            Id = "lkc-abc123",
            Environment = new ConfluentCloud.Inputs.GetKafkaClusterEnvironmentArgs
            {
                Id = "env-xyz456",
            },
        }));
        var test_sa = new ConfluentCloud.ServiceAccount("test-sa", new ConfluentCloud.ServiceAccountArgs
        {
            DisplayName = "app_mgr",
            Description = exampleUsingId.Apply(exampleUsingId => $"app_mgr for {exampleUsingId.DisplayName}"),
        });
        var exampleUsingNameKafkaCluster = Output.Create(ConfluentCloud.GetKafkaCluster.InvokeAsync(new ConfluentCloud.GetKafkaClusterArgs
        {
            DisplayName = "basic_kafka_cluster",
            Environment = new ConfluentCloud.Inputs.GetKafkaClusterEnvironmentArgs
            {
                Id = "env-xyz456",
            },
        }));
        this.ExampleUsingName = exampleUsingNameKafkaCluster;
    }

    [Output("exampleUsingName")]
    public Output<string> ExampleUsingName { get; set; }
}

    package main

import (
	"fmt"

	"github.com/pulumi/pulumi-confluentcloud/sdk/go/confluentcloud"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		exampleUsingId, err := confluentcloud.LookupKafkaCluster(ctx, &GetKafkaClusterArgs{
			Id: pulumi.StringRef("lkc-abc123"),
			Environment: GetKafkaClusterEnvironment{
				Id: "env-xyz456",
			},
		}, nil)
		if err != nil {
			return err
		}
		_, err = confluentcloud.NewServiceAccount(ctx, "test-sa", &confluentcloud.ServiceAccountArgs{
			DisplayName: pulumi.String("app_mgr"),
			Description: pulumi.String(fmt.Sprintf("%v%v", "app_mgr for ", exampleUsingId.DisplayName)),
		})
		if err != nil {
			return err
		}
		exampleUsingNameKafkaCluster, err := confluentcloud.LookupKafkaCluster(ctx, &GetKafkaClusterArgs{
			DisplayName: pulumi.StringRef("basic_kafka_cluster"),
			Environment: GetKafkaClusterEnvironment{
				Id: "env-xyz456",
			},
		}, nil)
		if err != nil {
			return err
		}
		ctx.Export("exampleUsingName", exampleUsingNameKafkaCluster)
		return nil
	})
}

    package generated_program;

import java.util.*;
import java.io.*;
import java.nio.*;
import com.pulumi.*;

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

    public static void stack(Context ctx) {
        final var exampleUsingId = Output.of(ConfluentcloudFunctions.getKafkaCluster(GetKafkaClusterArgs.builder()
            .id("lkc-abc123")
            .environment(GetKafkaClusterEnvironmentArgs.builder()
                .id("env-xyz456")
                .build())
            .build()));

        var test_sa = new ServiceAccount("test-sa", ServiceAccountArgs.builder()        
            .displayName("app_mgr")
            .description(String.format("app_mgr for %s", exampleUsingId.apply(getKafkaClusterResult -> getKafkaClusterResult.displayName())))
            .build());

        final var exampleUsingNameKafkaCluster = Output.of(ConfluentcloudFunctions.getKafkaCluster(GetKafkaClusterArgs.builder()
            .displayName("basic_kafka_cluster")
            .environment(GetKafkaClusterEnvironmentArgs.builder()
                .id("env-xyz456")
                .build())
            .build()));

        ctx.export("exampleUsingName", exampleUsingNameKafkaCluster.apply(getKafkaClusterResult -> getKafkaClusterResult));
    }
}

    import * as pulumi from "@pulumi/pulumi";
import * as confluentcloud from "@pulumi/confluentcloud";

const exampleUsingId = confluentcloud.getKafkaCluster({
    id: "lkc-abc123",
    environment: {
        id: "env-xyz456",
    },
});
const test_sa = new confluentcloud.ServiceAccount("test-sa", {
    displayName: "app_mgr",
    description: exampleUsingId.then(exampleUsingId => `app_mgr for ${exampleUsingId.displayName}`),
});
const exampleUsingNameKafkaCluster = confluentcloud.getKafkaCluster({
    displayName: "basic_kafka_cluster",
    environment: {
        id: "env-xyz456",
    },
});
export const exampleUsingName = exampleUsingNameKafkaCluster;

    import pulumi
import pulumi_confluentcloud as confluentcloud

example_using_id = confluentcloud.get_kafka_cluster(id="lkc-abc123",
    environment=confluentcloud.GetKafkaClusterEnvironmentArgs(
        id="env-xyz456",
    ))
test_sa = confluentcloud.ServiceAccount("test-sa",
    display_name="app_mgr",
    description=f"app_mgr for {example_using_id.display_name}")
example_using_name_kafka_cluster = confluentcloud.get_kafka_cluster(display_name="basic_kafka_cluster",
    environment=confluentcloud.GetKafkaClusterEnvironmentArgs(
        id="env-xyz456",
    ))
pulumi.export("exampleUsingName", example_using_name_kafka_cluster)

    resources:
  test-sa:
    type: confluentcloud:ServiceAccount
    properties:
      displayName: app_mgr
      description: app_mgr for ${exampleUsingId.displayName}
variables:
  exampleUsingId:
    Fn::Invoke:
      Function: confluentcloud:getKafkaCluster
      Arguments:
        id: lkc-abc123
        environment:
          id: env-xyz456
  exampleUsingNameKafkaCluster:
    Fn::Invoke:
      Function: confluentcloud:getKafkaCluster
      Arguments:
        displayName: basic_kafka_cluster
        environment:
          id: env-xyz456
outputs:
  exampleUsingName: ${exampleUsingNameKafkaCluster}

    Using getKafkaCluster

    Two invocation forms are available. The direct form accepts plain arguments and either blocks until the result value is available, or returns a Promise-wrapped result. The output form accepts Input-wrapped arguments and returns an Output-wrapped result.

    function getKafkaCluster(args: GetKafkaClusterArgs, opts?: InvokeOptions): Promise<GetKafkaClusterResult>
function getKafkaClusterOutput(args: GetKafkaClusterOutputArgs, opts?: InvokeOptions): Output<GetKafkaClusterResult>
    def get_kafka_cluster(basics: Optional[Sequence[GetKafkaClusterBasic]] = None,
                      dedicated: Optional[GetKafkaClusterDedicated] = None,
                      display_name: Optional[str] = None,
                      environment: Optional[GetKafkaClusterEnvironment] = None,
                      id: Optional[str] = None,
                      standards: Optional[Sequence[GetKafkaClusterStandard]] = None,
                      opts: Optional[InvokeOptions] = None) -> GetKafkaClusterResult
def get_kafka_cluster_output(basics: Optional[pulumi.Input[Sequence[pulumi.Input[GetKafkaClusterBasicArgs]]]] = None,
                      dedicated: Optional[pulumi.Input[GetKafkaClusterDedicatedArgs]] = None,
                      display_name: Optional[pulumi.Input[str]] = None,
                      environment: Optional[pulumi.Input[GetKafkaClusterEnvironmentArgs]] = None,
                      id: Optional[pulumi.Input[str]] = None,
                      standards: Optional[pulumi.Input[Sequence[pulumi.Input[GetKafkaClusterStandardArgs]]]] = None,
                      opts: Optional[InvokeOptions] = None) -> Output[GetKafkaClusterResult]
    func LookupKafkaCluster(ctx *Context, args *LookupKafkaClusterArgs, opts ...InvokeOption) (*LookupKafkaClusterResult, error)
func LookupKafkaClusterOutput(ctx *Context, args *LookupKafkaClusterOutputArgs, opts ...InvokeOption) LookupKafkaClusterResultOutput

    > Note: This function is named LookupKafkaCluster in the Go SDK.

    public static class GetKafkaCluster 
{
    public static Task<GetKafkaClusterResult> InvokeAsync(GetKafkaClusterArgs args, InvokeOptions? opts = null)
    public static Output<GetKafkaClusterResult> Invoke(GetKafkaClusterInvokeArgs args, InvokeOptions? opts = null)
}
    public static CompletableFuture<GetKafkaClusterResult> getKafkaCluster(GetKafkaClusterArgs args, InvokeOptions options)
public static Output<GetKafkaClusterResult> getKafkaCluster(GetKafkaClusterArgs args, InvokeOptions options)

    fn::invoke:
  function: confluentcloud:index/getKafkaCluster:getKafkaCluster
  arguments:
    # arguments dictionary

    The following arguments are supported:

    Environment Pulumi.ConfluentCloud.Inputs.GetKafkaClusterEnvironment
    Basics List<Pulumi.ConfluentCloud.Inputs.GetKafkaClusterBasic>
    (Optional Configuration Block) The configuration of the Basic Kafka cluster.
    Dedicated Pulumi.ConfluentCloud.Inputs.GetKafkaClusterDedicated
    (Optional Configuration Block) The configuration of the Dedicated Kafka cluster. It supports the following:
    DisplayName string
    A human-readable name for the Kafka cluster.
    Id string
    The ID of the Environment that the Kafka cluster belongs to, for example, env-xyz456.
    Standards List<Pulumi.ConfluentCloud.Inputs.GetKafkaClusterStandard>
    (Optional Configuration Block) The configuration of the Standard Kafka cluster.
    Environment GetKafkaClusterEnvironment
    Basics []GetKafkaClusterBasic
    (Optional Configuration Block) The configuration of the Basic Kafka cluster.
    Dedicated GetKafkaClusterDedicated
    (Optional Configuration Block) The configuration of the Dedicated Kafka cluster. It supports the following:
    DisplayName string
    A human-readable name for the Kafka cluster.
    Id string
    The ID of the Environment that the Kafka cluster belongs to, for example, env-xyz456.
    Standards []GetKafkaClusterStandard
    (Optional Configuration Block) The configuration of the Standard Kafka cluster.
    environment GetKafkaClusterEnvironment
    basics List<GetKafkaClusterBasic>
    (Optional Configuration Block) The configuration of the Basic Kafka cluster.
    dedicated GetKafkaClusterDedicated
    (Optional Configuration Block) The configuration of the Dedicated Kafka cluster. It supports the following:
    displayName String
    A human-readable name for the Kafka cluster.
    id String
    The ID of the Environment that the Kafka cluster belongs to, for example, env-xyz456.
    standards List<GetKafkaClusterStandard>
    (Optional Configuration Block) The configuration of the Standard Kafka cluster.
    environment GetKafkaClusterEnvironment
    basics GetKafkaClusterBasic[]
    (Optional Configuration Block) The configuration of the Basic Kafka cluster.
    dedicated GetKafkaClusterDedicated
    (Optional Configuration Block) The configuration of the Dedicated Kafka cluster. It supports the following:
    displayName string
    A human-readable name for the Kafka cluster.
    id string
    The ID of the Environment that the Kafka cluster belongs to, for example, env-xyz456.
    standards GetKafkaClusterStandard[]
    (Optional Configuration Block) The configuration of the Standard Kafka cluster.
    environment GetKafkaClusterEnvironment
    basics Sequence[GetKafkaClusterBasic]
    (Optional Configuration Block) The configuration of the Basic Kafka cluster.
    dedicated GetKafkaClusterDedicated
    (Optional Configuration Block) The configuration of the Dedicated Kafka cluster. It supports the following:
    display_name str
    A human-readable name for the Kafka cluster.
    id str
    The ID of the Environment that the Kafka cluster belongs to, for example, env-xyz456.
    standards Sequence[GetKafkaClusterStandard]
    (Optional Configuration Block) The configuration of the Standard Kafka cluster.
    environment Property Map
    basics List<Property Map>
    (Optional Configuration Block) The configuration of the Basic Kafka cluster.
    dedicated Property Map
    (Optional Configuration Block) The configuration of the Dedicated Kafka cluster. It supports the following:
    displayName String
    A human-readable name for the Kafka cluster.
    id String
    The ID of the Environment that the Kafka cluster belongs to, for example, env-xyz456.
    standards List<Property Map>
    (Optional Configuration Block) The configuration of the Standard Kafka cluster.

    getKafkaCluster Result

    The following output properties are available:

    ApiVersion string
    (Required String) An API Version of the schema version of the Kafka cluster, for example, cmk/v2.
    Availability string
    (Required String) The availability zone configuration of the Kafka cluster. Accepted values are: SINGLE_ZONE and MULTI_ZONE.
    BootstrapEndpoint string
    (Required String) The bootstrap endpoint used by Kafka clients to connect to the Kafka cluster. (e.g., pkc-00000.us-central1.gcp.confluent.cloud:9092).
    Cloud string
    (Required String) The cloud service provider that runs the Kafka cluster. Accepted values are: AWS, AZURE, and GCP.
    DisplayName string
    (Required String) The name of the Kafka cluster.
    Environment Pulumi.ConfluentCloud.Outputs.GetKafkaClusterEnvironment
    HttpEndpoint string
    (Required String) The REST endpoint of the Kafka cluster (e.g., https://pkc-00000.us-central1.gcp.confluent.cloud:443).
    Id string
    (Required String) The ID of the Network that the Kafka cluster belongs to, for example, n-abc123.
    Kind string
    (Required String) A kind of the Kafka cluster, for example, Cluster.
    Networks List<Pulumi.ConfluentCloud.Outputs.GetKafkaClusterNetwork>
    RbacCrn string
    (Required String) The Confluent Resource Name of the Kafka cluster, for example, crn://confluent.cloud/organization=1111aaaa-11aa-11aa-11aa-111111aaaaaa/environment=env-abc123/cloud-cluster=lkc-abc123.
    Region string
    (Required String) The cloud service provider region where the Kafka cluster is running, for example, us-west-2. See Cloud Providers and Regions for a full list of options for AWS, Azure, and GCP.
    Basics List<Pulumi.ConfluentCloud.Outputs.GetKafkaClusterBasic>
    (Optional Configuration Block) The configuration of the Basic Kafka cluster.
    Dedicated Pulumi.ConfluentCloud.Outputs.GetKafkaClusterDedicated
    (Optional Configuration Block) The configuration of the Dedicated Kafka cluster. It supports the following:
    Standards List<Pulumi.ConfluentCloud.Outputs.GetKafkaClusterStandard>
    (Optional Configuration Block) The configuration of the Standard Kafka cluster.
    ApiVersion string
    (Required String) An API Version of the schema version of the Kafka cluster, for example, cmk/v2.
    Availability string
    (Required String) The availability zone configuration of the Kafka cluster. Accepted values are: SINGLE_ZONE and MULTI_ZONE.
    BootstrapEndpoint string
    (Required String) The bootstrap endpoint used by Kafka clients to connect to the Kafka cluster. (e.g., pkc-00000.us-central1.gcp.confluent.cloud:9092).
    Cloud string
    (Required String) The cloud service provider that runs the Kafka cluster. Accepted values are: AWS, AZURE, and GCP.
    DisplayName string
    (Required String) The name of the Kafka cluster.
    Environment GetKafkaClusterEnvironment
    HttpEndpoint string
    (Required String) The REST endpoint of the Kafka cluster (e.g., https://pkc-00000.us-central1.gcp.confluent.cloud:443).
    Id string
    (Required String) The ID of the Network that the Kafka cluster belongs to, for example, n-abc123.
    Kind string
    (Required String) A kind of the Kafka cluster, for example, Cluster.
    Networks []GetKafkaClusterNetwork
    RbacCrn string
    (Required String) The Confluent Resource Name of the Kafka cluster, for example, crn://confluent.cloud/organization=1111aaaa-11aa-11aa-11aa-111111aaaaaa/environment=env-abc123/cloud-cluster=lkc-abc123.
    Region string
    (Required String) The cloud service provider region where the Kafka cluster is running, for example, us-west-2. See Cloud Providers and Regions for a full list of options for AWS, Azure, and GCP.
    Basics []GetKafkaClusterBasic
    (Optional Configuration Block) The configuration of the Basic Kafka cluster.
    Dedicated GetKafkaClusterDedicated
    (Optional Configuration Block) The configuration of the Dedicated Kafka cluster. It supports the following:
    Standards []GetKafkaClusterStandard
    (Optional Configuration Block) The configuration of the Standard Kafka cluster.
    apiVersion String
    (Required String) An API Version of the schema version of the Kafka cluster, for example, cmk/v2.
    availability String
    (Required String) The availability zone configuration of the Kafka cluster. Accepted values are: SINGLE_ZONE and MULTI_ZONE.
    bootstrapEndpoint String
    (Required String) The bootstrap endpoint used by Kafka clients to connect to the Kafka cluster. (e.g., pkc-00000.us-central1.gcp.confluent.cloud:9092).
    cloud String
    (Required String) The cloud service provider that runs the Kafka cluster. Accepted values are: AWS, AZURE, and GCP.
    displayName String
    (Required String) The name of the Kafka cluster.
    environment GetKafkaClusterEnvironment
    httpEndpoint String
    (Required String) The REST endpoint of the Kafka cluster (e.g., https://pkc-00000.us-central1.gcp.confluent.cloud:443).
    id String
    (Required String) The ID of the Network that the Kafka cluster belongs to, for example, n-abc123.
    kind String
    (Required String) A kind of the Kafka cluster, for example, Cluster.
    networks List<GetKafkaClusterNetwork>
    rbacCrn String
    (Required String) The Confluent Resource Name of the Kafka cluster, for example, crn://confluent.cloud/organization=1111aaaa-11aa-11aa-11aa-111111aaaaaa/environment=env-abc123/cloud-cluster=lkc-abc123.
    region String
    (Required String) The cloud service provider region where the Kafka cluster is running, for example, us-west-2. See Cloud Providers and Regions for a full list of options for AWS, Azure, and GCP.
    basics List<GetKafkaClusterBasic>
    (Optional Configuration Block) The configuration of the Basic Kafka cluster.
    dedicated GetKafkaClusterDedicated
    (Optional Configuration Block) The configuration of the Dedicated Kafka cluster. It supports the following:
    standards List<GetKafkaClusterStandard>
    (Optional Configuration Block) The configuration of the Standard Kafka cluster.
    apiVersion string
    (Required String) An API Version of the schema version of the Kafka cluster, for example, cmk/v2.
    availability string
    (Required String) The availability zone configuration of the Kafka cluster. Accepted values are: SINGLE_ZONE and MULTI_ZONE.
    bootstrapEndpoint string
    (Required String) The bootstrap endpoint used by Kafka clients to connect to the Kafka cluster. (e.g., pkc-00000.us-central1.gcp.confluent.cloud:9092).
    cloud string
    (Required String) The cloud service provider that runs the Kafka cluster. Accepted values are: AWS, AZURE, and GCP.
    displayName string
    (Required String) The name of the Kafka cluster.
    environment GetKafkaClusterEnvironment
    httpEndpoint string
    (Required String) The REST endpoint of the Kafka cluster (e.g., https://pkc-00000.us-central1.gcp.confluent.cloud:443).
    id string
    (Required String) The ID of the Network that the Kafka cluster belongs to, for example, n-abc123.
    kind string
    (Required String) A kind of the Kafka cluster, for example, Cluster.
    networks GetKafkaClusterNetwork[]
    rbacCrn string
    (Required String) The Confluent Resource Name of the Kafka cluster, for example, crn://confluent.cloud/organization=1111aaaa-11aa-11aa-11aa-111111aaaaaa/environment=env-abc123/cloud-cluster=lkc-abc123.
    region string
    (Required String) The cloud service provider region where the Kafka cluster is running, for example, us-west-2. See Cloud Providers and Regions for a full list of options for AWS, Azure, and GCP.
    basics GetKafkaClusterBasic[]
    (Optional Configuration Block) The configuration of the Basic Kafka cluster.
    dedicated GetKafkaClusterDedicated
    (Optional Configuration Block) The configuration of the Dedicated Kafka cluster. It supports the following:
    standards GetKafkaClusterStandard[]
    (Optional Configuration Block) The configuration of the Standard Kafka cluster.
    api_version str
    (Required String) An API Version of the schema version of the Kafka cluster, for example, cmk/v2.
    availability str
    (Required String) The availability zone configuration of the Kafka cluster. Accepted values are: SINGLE_ZONE and MULTI_ZONE.
    bootstrap_endpoint str
    (Required String) The bootstrap endpoint used by Kafka clients to connect to the Kafka cluster. (e.g., pkc-00000.us-central1.gcp.confluent.cloud:9092).
    cloud str
    (Required String) The cloud service provider that runs the Kafka cluster. Accepted values are: AWS, AZURE, and GCP.
    display_name str
    (Required String) The name of the Kafka cluster.
    environment GetKafkaClusterEnvironment
    http_endpoint str
    (Required String) The REST endpoint of the Kafka cluster (e.g., https://pkc-00000.us-central1.gcp.confluent.cloud:443).
    id str
    (Required String) The ID of the Network that the Kafka cluster belongs to, for example, n-abc123.
    kind str
    (Required String) A kind of the Kafka cluster, for example, Cluster.
    networks Sequence[GetKafkaClusterNetwork]
    rbac_crn str
    (Required String) The Confluent Resource Name of the Kafka cluster, for example, crn://confluent.cloud/organization=1111aaaa-11aa-11aa-11aa-111111aaaaaa/environment=env-abc123/cloud-cluster=lkc-abc123.
    region str
    (Required String) The cloud service provider region where the Kafka cluster is running, for example, us-west-2. See Cloud Providers and Regions for a full list of options for AWS, Azure, and GCP.
    basics Sequence[GetKafkaClusterBasic]
    (Optional Configuration Block) The configuration of the Basic Kafka cluster.
    dedicated GetKafkaClusterDedicated
    (Optional Configuration Block) The configuration of the Dedicated Kafka cluster. It supports the following:
    standards Sequence[GetKafkaClusterStandard]
    (Optional Configuration Block) The configuration of the Standard Kafka cluster.
    apiVersion String
    (Required String) An API Version of the schema version of the Kafka cluster, for example, cmk/v2.
    availability String
    (Required String) The availability zone configuration of the Kafka cluster. Accepted values are: SINGLE_ZONE and MULTI_ZONE.
    bootstrapEndpoint String
    (Required String) The bootstrap endpoint used by Kafka clients to connect to the Kafka cluster. (e.g., pkc-00000.us-central1.gcp.confluent.cloud:9092).
    cloud String
    (Required String) The cloud service provider that runs the Kafka cluster. Accepted values are: AWS, AZURE, and GCP.
    displayName String
    (Required String) The name of the Kafka cluster.
    environment Property Map
    httpEndpoint String
    (Required String) The REST endpoint of the Kafka cluster (e.g., https://pkc-00000.us-central1.gcp.confluent.cloud:443).
    id String
    (Required String) The ID of the Network that the Kafka cluster belongs to, for example, n-abc123.
    kind String
    (Required String) A kind of the Kafka cluster, for example, Cluster.
    networks List<Property Map>
    rbacCrn String
    (Required String) The Confluent Resource Name of the Kafka cluster, for example, crn://confluent.cloud/organization=1111aaaa-11aa-11aa-11aa-111111aaaaaa/environment=env-abc123/cloud-cluster=lkc-abc123.
    region String
    (Required String) The cloud service provider region where the Kafka cluster is running, for example, us-west-2. See Cloud Providers and Regions for a full list of options for AWS, Azure, and GCP.
    basics List<Property Map>
    (Optional Configuration Block) The configuration of the Basic Kafka cluster.
    dedicated Property Map
    (Optional Configuration Block) The configuration of the Dedicated Kafka cluster. It supports the following:
    standards List<Property Map>
    (Optional Configuration Block) The configuration of the Standard Kafka cluster.

    Supporting Types

    GetKafkaClusterDedicated

    Cku int
    (Required Number) The number of Confluent Kafka Units (CKUs) for Dedicated cluster types. The minimum number of CKUs for SINGLE_ZONE dedicated clusters is 1 whereas MULTI_ZONE dedicated clusters must have more than 2 CKUs.
    EncryptionKey string
    (Optional String) The ID of the encryption key that is used to encrypt the data in the Kafka cluster, for example, arn:aws:kms:us-west-2:111122223333:key/1234abcd-12ab-34cd-56ef-1234567890ab (key Amazon Resource Name) for AWS or projects/my-test-project/locations/global/keyRings/test-byok/cryptoKeys/test for GCP. Append required permissions to the key policy before creating a Kafka cluster, see Encrypt Confluent Cloud Clusters using Self-Managed Keys for more details. At the moment, self-managed encryption keys are only available for the Dedicated clusters on AWS or GCP.
    Cku int
    (Required Number) The number of Confluent Kafka Units (CKUs) for Dedicated cluster types. The minimum number of CKUs for SINGLE_ZONE dedicated clusters is 1 whereas MULTI_ZONE dedicated clusters must have more than 2 CKUs.
    EncryptionKey string
    (Optional String) The ID of the encryption key that is used to encrypt the data in the Kafka cluster, for example, arn:aws:kms:us-west-2:111122223333:key/1234abcd-12ab-34cd-56ef-1234567890ab (key Amazon Resource Name) for AWS or projects/my-test-project/locations/global/keyRings/test-byok/cryptoKeys/test for GCP. Append required permissions to the key policy before creating a Kafka cluster, see Encrypt Confluent Cloud Clusters using Self-Managed Keys for more details. At the moment, self-managed encryption keys are only available for the Dedicated clusters on AWS or GCP.
    cku Integer
    (Required Number) The number of Confluent Kafka Units (CKUs) for Dedicated cluster types. The minimum number of CKUs for SINGLE_ZONE dedicated clusters is 1 whereas MULTI_ZONE dedicated clusters must have more than 2 CKUs.
    encryptionKey String
    (Optional String) The ID of the encryption key that is used to encrypt the data in the Kafka cluster, for example, arn:aws:kms:us-west-2:111122223333:key/1234abcd-12ab-34cd-56ef-1234567890ab (key Amazon Resource Name) for AWS or projects/my-test-project/locations/global/keyRings/test-byok/cryptoKeys/test for GCP. Append required permissions to the key policy before creating a Kafka cluster, see Encrypt Confluent Cloud Clusters using Self-Managed Keys for more details. At the moment, self-managed encryption keys are only available for the Dedicated clusters on AWS or GCP.
    cku number
    (Required Number) The number of Confluent Kafka Units (CKUs) for Dedicated cluster types. The minimum number of CKUs for SINGLE_ZONE dedicated clusters is 1 whereas MULTI_ZONE dedicated clusters must have more than 2 CKUs.
    encryptionKey string
    (Optional String) The ID of the encryption key that is used to encrypt the data in the Kafka cluster, for example, arn:aws:kms:us-west-2:111122223333:key/1234abcd-12ab-34cd-56ef-1234567890ab (key Amazon Resource Name) for AWS or projects/my-test-project/locations/global/keyRings/test-byok/cryptoKeys/test for GCP. Append required permissions to the key policy before creating a Kafka cluster, see Encrypt Confluent Cloud Clusters using Self-Managed Keys for more details. At the moment, self-managed encryption keys are only available for the Dedicated clusters on AWS or GCP.
    cku int
    (Required Number) The number of Confluent Kafka Units (CKUs) for Dedicated cluster types. The minimum number of CKUs for SINGLE_ZONE dedicated clusters is 1 whereas MULTI_ZONE dedicated clusters must have more than 2 CKUs.
    encryption_key str
    (Optional String) The ID of the encryption key that is used to encrypt the data in the Kafka cluster, for example, arn:aws:kms:us-west-2:111122223333:key/1234abcd-12ab-34cd-56ef-1234567890ab (key Amazon Resource Name) for AWS or projects/my-test-project/locations/global/keyRings/test-byok/cryptoKeys/test for GCP. Append required permissions to the key policy before creating a Kafka cluster, see Encrypt Confluent Cloud Clusters using Self-Managed Keys for more details. At the moment, self-managed encryption keys are only available for the Dedicated clusters on AWS or GCP.
    cku Number
    (Required Number) The number of Confluent Kafka Units (CKUs) for Dedicated cluster types. The minimum number of CKUs for SINGLE_ZONE dedicated clusters is 1 whereas MULTI_ZONE dedicated clusters must have more than 2 CKUs.
    encryptionKey String
    (Optional String) The ID of the encryption key that is used to encrypt the data in the Kafka cluster, for example, arn:aws:kms:us-west-2:111122223333:key/1234abcd-12ab-34cd-56ef-1234567890ab (key Amazon Resource Name) for AWS or projects/my-test-project/locations/global/keyRings/test-byok/cryptoKeys/test for GCP. Append required permissions to the key policy before creating a Kafka cluster, see Encrypt Confluent Cloud Clusters using Self-Managed Keys for more details. At the moment, self-managed encryption keys are only available for the Dedicated clusters on AWS or GCP.

    GetKafkaClusterEnvironment

    Id string
    The ID of the Environment that the Kafka cluster belongs to, for example, env-xyz456.
    Id string
    The ID of the Environment that the Kafka cluster belongs to, for example, env-xyz456.
    id String
    The ID of the Environment that the Kafka cluster belongs to, for example, env-xyz456.
    id string
    The ID of the Environment that the Kafka cluster belongs to, for example, env-xyz456.
    id str
    The ID of the Environment that the Kafka cluster belongs to, for example, env-xyz456.
    id String
    The ID of the Environment that the Kafka cluster belongs to, for example, env-xyz456.

    GetKafkaClusterNetwork

    Id string
    The ID of the Environment that the Kafka cluster belongs to, for example, env-xyz456.
    Id string
    The ID of the Environment that the Kafka cluster belongs to, for example, env-xyz456.
    id String
    The ID of the Environment that the Kafka cluster belongs to, for example, env-xyz456.
    id string
    The ID of the Environment that the Kafka cluster belongs to, for example, env-xyz456.
    id str
    The ID of the Environment that the Kafka cluster belongs to, for example, env-xyz456.
    id String
    The ID of the Environment that the Kafka cluster belongs to, for example, env-xyz456.

    Package Details

    Repository
    Confluent Cloud pulumi/pulumi-confluentcloud
    License
    Apache-2.0
    Notes
    This Pulumi package is based on the confluent Terraform Provider.
    confluentcloud logo
    Viewing docs for Confluent v0.1.0 (Older version)
    published on Monday, Mar 9, 2026 by Pulumi
    Go to latest version
    Schema (JSON)
    pulumi/pulumi-confluentcloud
      Try Pulumi Cloud free. Your team will thank you.