1. Packages
  2. Oracle Cloud Infrastructure
  3. API Docs
  4. oci
  5. getManagedKafkaKafkaCluster
Oracle Cloud Infrastructure v3.12.0 published on Friday, Nov 21, 2025 by Pulumi
Schema (JSON)
pulumi/pulumi-oci

oci.oci.getManagedKafkaKafkaCluster

oci logo
Oracle Cloud Infrastructure v3.12.0 published on Friday, Nov 21, 2025 by Pulumi
Schema (JSON)
pulumi/pulumi-oci

    This data source provides details about a specific Kafka Cluster resource in Oracle Cloud Infrastructure Managed Kafka service.

    Gets information about a KafkaCluster.

    Example Usage

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

const testKafkaCluster = oci.oci.getManagedKafkaKafkaCluster({
    kafkaClusterId: testKafkaClusterOciManagedKafkaKafkaCluster.id,
});

    import pulumi
import pulumi_oci as oci

test_kafka_cluster = oci.oci.get_managed_kafka_kafka_cluster(kafka_cluster_id=test_kafka_cluster_oci_managed_kafka_kafka_cluster["id"])

    package main

import (
	"github.com/pulumi/pulumi-oci/sdk/v3/go/oci/oci"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := oci.LookupManagedKafkaKafkaCluster(ctx, &oci.LookupManagedKafkaKafkaClusterArgs{
			KafkaClusterId: testKafkaClusterOciManagedKafkaKafkaCluster.Id,
		}, nil)
		if err != nil {
			return err
		}
		return nil
	})
}

    using System.Collections.Generic;
using System.Linq;
using Pulumi;
using Oci = Pulumi.Oci;

return await Deployment.RunAsync(() => 
{
    var testKafkaCluster = Oci.Oci.GetManagedKafkaKafkaCluster.Invoke(new()
    {
        KafkaClusterId = testKafkaClusterOciManagedKafkaKafkaCluster.Id,
    });

});

    package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.oci.oci.OciFunctions;
import com.pulumi.oci.oci.inputs.GetManagedKafkaKafkaClusterArgs;
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) {
        final var testKafkaCluster = OciFunctions.getManagedKafkaKafkaCluster(GetManagedKafkaKafkaClusterArgs.builder()
            .kafkaClusterId(testKafkaClusterOciManagedKafkaKafkaCluster.id())
            .build());

    }
}

    variables:
  testKafkaCluster:
    fn::invoke:
      function: oci:oci:getManagedKafkaKafkaCluster
      arguments:
        kafkaClusterId: ${testKafkaClusterOciManagedKafkaKafkaCluster.id}

    Using getManagedKafkaKafkaCluster

    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 getManagedKafkaKafkaCluster(args: GetManagedKafkaKafkaClusterArgs, opts?: InvokeOptions): Promise<GetManagedKafkaKafkaClusterResult>
function getManagedKafkaKafkaClusterOutput(args: GetManagedKafkaKafkaClusterOutputArgs, opts?: InvokeOptions): Output<GetManagedKafkaKafkaClusterResult>
    def get_managed_kafka_kafka_cluster(kafka_cluster_id: Optional[str] = None,
                                    opts: Optional[InvokeOptions] = None) -> GetManagedKafkaKafkaClusterResult
def get_managed_kafka_kafka_cluster_output(kafka_cluster_id: Optional[pulumi.Input[str]] = None,
                                    opts: Optional[InvokeOptions] = None) -> Output[GetManagedKafkaKafkaClusterResult]
    func LookupManagedKafkaKafkaCluster(ctx *Context, args *LookupManagedKafkaKafkaClusterArgs, opts ...InvokeOption) (*LookupManagedKafkaKafkaClusterResult, error)
func LookupManagedKafkaKafkaClusterOutput(ctx *Context, args *LookupManagedKafkaKafkaClusterOutputArgs, opts ...InvokeOption) LookupManagedKafkaKafkaClusterResultOutput

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

    public static class GetManagedKafkaKafkaCluster 
{
    public static Task<GetManagedKafkaKafkaClusterResult> InvokeAsync(GetManagedKafkaKafkaClusterArgs args, InvokeOptions? opts = null)
    public static Output<GetManagedKafkaKafkaClusterResult> Invoke(GetManagedKafkaKafkaClusterInvokeArgs args, InvokeOptions? opts = null)
}
    public static CompletableFuture<GetManagedKafkaKafkaClusterResult> getManagedKafkaKafkaCluster(GetManagedKafkaKafkaClusterArgs args, InvokeOptions options)
public static Output<GetManagedKafkaKafkaClusterResult> getManagedKafkaKafkaCluster(GetManagedKafkaKafkaClusterArgs args, InvokeOptions options)

    fn::invoke:
  function: oci:oci/getManagedKafkaKafkaCluster:getManagedKafkaKafkaCluster
  arguments:
    # arguments dictionary

    The following arguments are supported:

    KafkaClusterId string
    The OCID of the KafkaCluster.
    KafkaClusterId string
    The OCID of the KafkaCluster.
    kafkaClusterId String
    The OCID of the KafkaCluster.
    kafkaClusterId string
    The OCID of the KafkaCluster.
    kafka_cluster_id str
    The OCID of the KafkaCluster.
    kafkaClusterId String
    The OCID of the KafkaCluster.

    getManagedKafkaKafkaCluster Result

    The following output properties are available:

    AccessSubnets List<GetManagedKafkaKafkaClusterAccessSubnet>
    Subnets where broker/coordinator VNICs will be created.
    BrokerShapes List<GetManagedKafkaKafkaClusterBrokerShape>
    Configuration of the broker node.
    ClientCertificateBundle string
    CA certificate bundle for mTLS broker authentication.
    ClusterConfigId string
    The OCID of Kafka Cluster configuration object
    ClusterConfigVersion int
    The version of configuration object
    ClusterType string
    Type of the cluster to spin up. DEVELOPMENT - setting that allows to sacrifice HA and spin up cluster on a single node PRODUCTION - Minimum allowed broker count is 3
    CompartmentId string
    The OCID of the compartment.
    CoordinationType string
    Kafka coordination type. Set of available types depends on Kafka version
    DefinedTags Dictionary<string, string>
    Defined tags for this resource. Each key is predefined and scoped to a namespace. For more information, see Resource Tags. Example: {"Operations.CostCenter": "42"}
    DisplayName string
    A user-friendly name. Does not have to be unique, and it's changeable.
    FreeformTags Dictionary<string, string>
    Free-form tags for this resource. Each tag is a simple key-value pair with no predefined name, type, or namespace. For more information, see Resource Tags. Example: {"Department": "Finance"}
    Id string
    The OCID of the KafkaCluster.
    KafkaBootstrapUrls List<GetManagedKafkaKafkaClusterKafkaBootstrapUrl>
    Bootstrap URL that can be used to connect to Kafka
    KafkaClusterId string
    KafkaVersion string
    Version of Kafka to use to spin up the cluster
    LifecycleDetails string
    A message that describes the current state of the KafkaCluster in more detail. For example, can be used to provide actionable information for a resource in the Failed state.
    SecretId string
    The OCID of the secret that contains superuser password.
    State string
    The current state of the KafkaCluster.
    SystemTags Dictionary<string, string>
    System tags for this resource. Each key is predefined and scoped to a namespace. Example: {"orcl-cloud.free-tier-retained": "true"}
    TimeCreated string
    The date and time the KafkaCluster was created, in the format defined by RFC 3339. Example: 2016-08-25T21:10:29.600Z
    TimeUpdated string
    The date and time the KafkaCluster was updated, in the format defined by RFC 3339. Example: 2016-08-25T21:10:29.600Z
    AccessSubnets []GetManagedKafkaKafkaClusterAccessSubnet
    Subnets where broker/coordinator VNICs will be created.
    BrokerShapes []GetManagedKafkaKafkaClusterBrokerShape
    Configuration of the broker node.
    ClientCertificateBundle string
    CA certificate bundle for mTLS broker authentication.
    ClusterConfigId string
    The OCID of Kafka Cluster configuration object
    ClusterConfigVersion int
    The version of configuration object
    ClusterType string
    Type of the cluster to spin up. DEVELOPMENT - setting that allows to sacrifice HA and spin up cluster on a single node PRODUCTION - Minimum allowed broker count is 3
    CompartmentId string
    The OCID of the compartment.
    CoordinationType string
    Kafka coordination type. Set of available types depends on Kafka version
    DefinedTags map[string]string
    Defined tags for this resource. Each key is predefined and scoped to a namespace. For more information, see Resource Tags. Example: {"Operations.CostCenter": "42"}
    DisplayName string
    A user-friendly name. Does not have to be unique, and it's changeable.
    FreeformTags map[string]string
    Free-form tags for this resource. Each tag is a simple key-value pair with no predefined name, type, or namespace. For more information, see Resource Tags. Example: {"Department": "Finance"}
    Id string
    The OCID of the KafkaCluster.
    KafkaBootstrapUrls []GetManagedKafkaKafkaClusterKafkaBootstrapUrl
    Bootstrap URL that can be used to connect to Kafka
    KafkaClusterId string
    KafkaVersion string
    Version of Kafka to use to spin up the cluster
    LifecycleDetails string
    A message that describes the current state of the KafkaCluster in more detail. For example, can be used to provide actionable information for a resource in the Failed state.
    SecretId string
    The OCID of the secret that contains superuser password.
    State string
    The current state of the KafkaCluster.
    SystemTags map[string]string
    System tags for this resource. Each key is predefined and scoped to a namespace. Example: {"orcl-cloud.free-tier-retained": "true"}
    TimeCreated string
    The date and time the KafkaCluster was created, in the format defined by RFC 3339. Example: 2016-08-25T21:10:29.600Z
    TimeUpdated string
    The date and time the KafkaCluster was updated, in the format defined by RFC 3339. Example: 2016-08-25T21:10:29.600Z
    accessSubnets List<GetManagedKafkaKafkaClusterAccessSubnet>
    Subnets where broker/coordinator VNICs will be created.
    brokerShapes List<GetManagedKafkaKafkaClusterBrokerShape>
    Configuration of the broker node.
    clientCertificateBundle String
    CA certificate bundle for mTLS broker authentication.
    clusterConfigId String
    The OCID of Kafka Cluster configuration object
    clusterConfigVersion Integer
    The version of configuration object
    clusterType String
    Type of the cluster to spin up. DEVELOPMENT - setting that allows to sacrifice HA and spin up cluster on a single node PRODUCTION - Minimum allowed broker count is 3
    compartmentId String
    The OCID of the compartment.
    coordinationType String
    Kafka coordination type. Set of available types depends on Kafka version
    definedTags Map<String,String>
    Defined tags for this resource. Each key is predefined and scoped to a namespace. For more information, see Resource Tags. Example: {"Operations.CostCenter": "42"}
    displayName String
    A user-friendly name. Does not have to be unique, and it's changeable.
    freeformTags Map<String,String>
    Free-form tags for this resource. Each tag is a simple key-value pair with no predefined name, type, or namespace. For more information, see Resource Tags. Example: {"Department": "Finance"}
    id String
    The OCID of the KafkaCluster.
    kafkaBootstrapUrls List<GetManagedKafkaKafkaClusterKafkaBootstrapUrl>
    Bootstrap URL that can be used to connect to Kafka
    kafkaClusterId String
    kafkaVersion String
    Version of Kafka to use to spin up the cluster
    lifecycleDetails String
    A message that describes the current state of the KafkaCluster in more detail. For example, can be used to provide actionable information for a resource in the Failed state.
    secretId String
    The OCID of the secret that contains superuser password.
    state String
    The current state of the KafkaCluster.
    systemTags Map<String,String>
    System tags for this resource. Each key is predefined and scoped to a namespace. Example: {"orcl-cloud.free-tier-retained": "true"}
    timeCreated String
    The date and time the KafkaCluster was created, in the format defined by RFC 3339. Example: 2016-08-25T21:10:29.600Z
    timeUpdated String
    The date and time the KafkaCluster was updated, in the format defined by RFC 3339. Example: 2016-08-25T21:10:29.600Z
    accessSubnets GetManagedKafkaKafkaClusterAccessSubnet[]
    Subnets where broker/coordinator VNICs will be created.
    brokerShapes GetManagedKafkaKafkaClusterBrokerShape[]
    Configuration of the broker node.
    clientCertificateBundle string
    CA certificate bundle for mTLS broker authentication.
    clusterConfigId string
    The OCID of Kafka Cluster configuration object
    clusterConfigVersion number
    The version of configuration object
    clusterType string
    Type of the cluster to spin up. DEVELOPMENT - setting that allows to sacrifice HA and spin up cluster on a single node PRODUCTION - Minimum allowed broker count is 3
    compartmentId string
    The OCID of the compartment.
    coordinationType string
    Kafka coordination type. Set of available types depends on Kafka version
    definedTags {[key: string]: string}
    Defined tags for this resource. Each key is predefined and scoped to a namespace. For more information, see Resource Tags. Example: {"Operations.CostCenter": "42"}
    displayName string
    A user-friendly name. Does not have to be unique, and it's changeable.
    freeformTags {[key: string]: string}
    Free-form tags for this resource. Each tag is a simple key-value pair with no predefined name, type, or namespace. For more information, see Resource Tags. Example: {"Department": "Finance"}
    id string
    The OCID of the KafkaCluster.
    kafkaBootstrapUrls GetManagedKafkaKafkaClusterKafkaBootstrapUrl[]
    Bootstrap URL that can be used to connect to Kafka
    kafkaClusterId string
    kafkaVersion string
    Version of Kafka to use to spin up the cluster
    lifecycleDetails string
    A message that describes the current state of the KafkaCluster in more detail. For example, can be used to provide actionable information for a resource in the Failed state.
    secretId string
    The OCID of the secret that contains superuser password.
    state string
    The current state of the KafkaCluster.
    systemTags {[key: string]: string}
    System tags for this resource. Each key is predefined and scoped to a namespace. Example: {"orcl-cloud.free-tier-retained": "true"}
    timeCreated string
    The date and time the KafkaCluster was created, in the format defined by RFC 3339. Example: 2016-08-25T21:10:29.600Z
    timeUpdated string
    The date and time the KafkaCluster was updated, in the format defined by RFC 3339. Example: 2016-08-25T21:10:29.600Z
    access_subnets Sequence[GetManagedKafkaKafkaClusterAccessSubnet]
    Subnets where broker/coordinator VNICs will be created.
    broker_shapes Sequence[GetManagedKafkaKafkaClusterBrokerShape]
    Configuration of the broker node.
    client_certificate_bundle str
    CA certificate bundle for mTLS broker authentication.
    cluster_config_id str
    The OCID of Kafka Cluster configuration object
    cluster_config_version int
    The version of configuration object
    cluster_type str
    Type of the cluster to spin up. DEVELOPMENT - setting that allows to sacrifice HA and spin up cluster on a single node PRODUCTION - Minimum allowed broker count is 3
    compartment_id str
    The OCID of the compartment.
    coordination_type str
    Kafka coordination type. Set of available types depends on Kafka version
    defined_tags Mapping[str, str]
    Defined tags for this resource. Each key is predefined and scoped to a namespace. For more information, see Resource Tags. Example: {"Operations.CostCenter": "42"}
    display_name str
    A user-friendly name. Does not have to be unique, and it's changeable.
    freeform_tags Mapping[str, str]
    Free-form tags for this resource. Each tag is a simple key-value pair with no predefined name, type, or namespace. For more information, see Resource Tags. Example: {"Department": "Finance"}
    id str
    The OCID of the KafkaCluster.
    kafka_bootstrap_urls Sequence[GetManagedKafkaKafkaClusterKafkaBootstrapUrl]
    Bootstrap URL that can be used to connect to Kafka
    kafka_cluster_id str
    kafka_version str
    Version of Kafka to use to spin up the cluster
    lifecycle_details str
    A message that describes the current state of the KafkaCluster in more detail. For example, can be used to provide actionable information for a resource in the Failed state.
    secret_id str
    The OCID of the secret that contains superuser password.
    state str
    The current state of the KafkaCluster.
    system_tags Mapping[str, str]
    System tags for this resource. Each key is predefined and scoped to a namespace. Example: {"orcl-cloud.free-tier-retained": "true"}
    time_created str
    The date and time the KafkaCluster was created, in the format defined by RFC 3339. Example: 2016-08-25T21:10:29.600Z
    time_updated str
    The date and time the KafkaCluster was updated, in the format defined by RFC 3339. Example: 2016-08-25T21:10:29.600Z
    accessSubnets List<Property Map>
    Subnets where broker/coordinator VNICs will be created.
    brokerShapes List<Property Map>
    Configuration of the broker node.
    clientCertificateBundle String
    CA certificate bundle for mTLS broker authentication.
    clusterConfigId String
    The OCID of Kafka Cluster configuration object
    clusterConfigVersion Number
    The version of configuration object
    clusterType String
    Type of the cluster to spin up. DEVELOPMENT - setting that allows to sacrifice HA and spin up cluster on a single node PRODUCTION - Minimum allowed broker count is 3
    compartmentId String
    The OCID of the compartment.
    coordinationType String
    Kafka coordination type. Set of available types depends on Kafka version
    definedTags Map<String>
    Defined tags for this resource. Each key is predefined and scoped to a namespace. For more information, see Resource Tags. Example: {"Operations.CostCenter": "42"}
    displayName String
    A user-friendly name. Does not have to be unique, and it's changeable.
    freeformTags Map<String>
    Free-form tags for this resource. Each tag is a simple key-value pair with no predefined name, type, or namespace. For more information, see Resource Tags. Example: {"Department": "Finance"}
    id String
    The OCID of the KafkaCluster.
    kafkaBootstrapUrls List<Property Map>
    Bootstrap URL that can be used to connect to Kafka
    kafkaClusterId String
    kafkaVersion String
    Version of Kafka to use to spin up the cluster
    lifecycleDetails String
    A message that describes the current state of the KafkaCluster in more detail. For example, can be used to provide actionable information for a resource in the Failed state.
    secretId String
    The OCID of the secret that contains superuser password.
    state String
    The current state of the KafkaCluster.
    systemTags Map<String>
    System tags for this resource. Each key is predefined and scoped to a namespace. Example: {"orcl-cloud.free-tier-retained": "true"}
    timeCreated String
    The date and time the KafkaCluster was created, in the format defined by RFC 3339. Example: 2016-08-25T21:10:29.600Z
    timeUpdated String
    The date and time the KafkaCluster was updated, in the format defined by RFC 3339. Example: 2016-08-25T21:10:29.600Z

    Supporting Types

    GetManagedKafkaKafkaClusterAccessSubnet

    Subnets List<string>
    Subnets OCIDs
    Subnets []string
    Subnets OCIDs
    subnets List<String>
    Subnets OCIDs
    subnets string[]
    Subnets OCIDs
    subnets Sequence[str]
    Subnets OCIDs
    subnets List<String>
    Subnets OCIDs

    GetManagedKafkaKafkaClusterBrokerShape

    NodeCount int
    Number of Kafka broker nodes
    OcpuCount int
    Number of OCPUs per nodes
    StorageSizeInGbs int
    Size of the storage per nodes.
    NodeCount int
    Number of Kafka broker nodes
    OcpuCount int
    Number of OCPUs per nodes
    StorageSizeInGbs int
    Size of the storage per nodes.
    nodeCount Integer
    Number of Kafka broker nodes
    ocpuCount Integer
    Number of OCPUs per nodes
    storageSizeInGbs Integer
    Size of the storage per nodes.
    nodeCount number
    Number of Kafka broker nodes
    ocpuCount number
    Number of OCPUs per nodes
    storageSizeInGbs number
    Size of the storage per nodes.
    node_count int
    Number of Kafka broker nodes
    ocpu_count int
    Number of OCPUs per nodes
    storage_size_in_gbs int
    Size of the storage per nodes.
    nodeCount Number
    Number of Kafka broker nodes
    ocpuCount Number
    Number of OCPUs per nodes
    storageSizeInGbs Number
    Size of the storage per nodes.

    GetManagedKafkaKafkaClusterKafkaBootstrapUrl

    Name string
    Name of the Kafka listener providing this bootstrap URL
    Url string
    Bootstrap URL
    Name string
    Name of the Kafka listener providing this bootstrap URL
    Url string
    Bootstrap URL
    name String
    Name of the Kafka listener providing this bootstrap URL
    url String
    Bootstrap URL
    name string
    Name of the Kafka listener providing this bootstrap URL
    url string
    Bootstrap URL
    name str
    Name of the Kafka listener providing this bootstrap URL
    url str
    Bootstrap URL
    name String
    Name of the Kafka listener providing this bootstrap URL
    url String
    Bootstrap URL

    Package Details

    Repository
    oci pulumi/pulumi-oci
    License
    Apache-2.0
    Notes
    This Pulumi package is based on the oci Terraform Provider.
    oci logo
    Oracle Cloud Infrastructure v3.12.0 published on Friday, Nov 21, 2025 by Pulumi
    Schema (JSON)
    pulumi/pulumi-oci
      Meet Neo: Your AI Platform Teammate