1. Packages
  2. MongoDB Atlas
  3. API Docs
  4. StreamConnection
MongoDB Atlas v3.16.2 published on Friday, Jun 21, 2024 by Pulumi

mongodbatlas.StreamConnection

Explore with Pulumi AI

mongodbatlas logo
MongoDB Atlas v3.16.2 published on Friday, Jun 21, 2024 by Pulumi

    mongodbatlas.StreamConnection provides a Stream Connection resource. The resource lets you create, edit, and delete stream instance connections.

    IMPORTANT: All arguments including the Kafka authentication password will be stored in the raw state as plaintext. Read more about sensitive data in state.

    Example Usage

    Example Cluster Connection

    import * as pulumi from "@pulumi/pulumi";
    import * as mongodbatlas from "@pulumi/mongodbatlas";
    
    const test = new mongodbatlas.StreamConnection("test", {
        projectId: projectId,
        instanceName: "InstanceName",
        connectionName: "ConnectionName",
        type: "Cluster",
        clusterName: "Cluster0",
    });
    
    import pulumi
    import pulumi_mongodbatlas as mongodbatlas
    
    test = mongodbatlas.StreamConnection("test",
        project_id=project_id,
        instance_name="InstanceName",
        connection_name="ConnectionName",
        type="Cluster",
        cluster_name="Cluster0")
    
    package main
    
    import (
    	"github.com/pulumi/pulumi-mongodbatlas/sdk/v3/go/mongodbatlas"
    	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
    )
    
    func main() {
    	pulumi.Run(func(ctx *pulumi.Context) error {
    		_, err := mongodbatlas.NewStreamConnection(ctx, "test", &mongodbatlas.StreamConnectionArgs{
    			ProjectId:      pulumi.Any(projectId),
    			InstanceName:   pulumi.String("InstanceName"),
    			ConnectionName: pulumi.String("ConnectionName"),
    			Type:           pulumi.String("Cluster"),
    			ClusterName:    pulumi.String("Cluster0"),
    		})
    		if err != nil {
    			return err
    		}
    		return nil
    	})
    }
    
    using System.Collections.Generic;
    using System.Linq;
    using Pulumi;
    using Mongodbatlas = Pulumi.Mongodbatlas;
    
    return await Deployment.RunAsync(() => 
    {
        var test = new Mongodbatlas.StreamConnection("test", new()
        {
            ProjectId = projectId,
            InstanceName = "InstanceName",
            ConnectionName = "ConnectionName",
            Type = "Cluster",
            ClusterName = "Cluster0",
        });
    
    });
    
    package generated_program;
    
    import com.pulumi.Context;
    import com.pulumi.Pulumi;
    import com.pulumi.core.Output;
    import com.pulumi.mongodbatlas.StreamConnection;
    import com.pulumi.mongodbatlas.StreamConnectionArgs;
    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 test = new StreamConnection("test", StreamConnectionArgs.builder()
                .projectId(projectId)
                .instanceName("InstanceName")
                .connectionName("ConnectionName")
                .type("Cluster")
                .clusterName("Cluster0")
                .build());
    
        }
    }
    
    resources:
      test:
        type: mongodbatlas:StreamConnection
        properties:
          projectId: ${projectId}
          instanceName: InstanceName
          connectionName: ConnectionName
          type: Cluster
          clusterName: Cluster0
    

    Example Kafka Plaintext Connection

    import * as pulumi from "@pulumi/pulumi";
    import * as mongodbatlas from "@pulumi/mongodbatlas";
    
    const test = new mongodbatlas.StreamConnection("test", {
        projectId: projectId,
        instanceName: "NewInstance",
        connectionName: "KafkaConnection",
        type: "Kafka",
        authentication: {
            mechanism: "SCRAM-256",
            username: "user",
            password: "somepassword",
        },
        security: {
            protocol: "PLAINTEXT",
        },
        config: {
            "auto.offset.reset": "latest",
        },
        bootstrapServers: "localhost:9091,localhost:9092",
    });
    
    import pulumi
    import pulumi_mongodbatlas as mongodbatlas
    
    test = mongodbatlas.StreamConnection("test",
        project_id=project_id,
        instance_name="NewInstance",
        connection_name="KafkaConnection",
        type="Kafka",
        authentication=mongodbatlas.StreamConnectionAuthenticationArgs(
            mechanism="SCRAM-256",
            username="user",
            password="somepassword",
        ),
        security=mongodbatlas.StreamConnectionSecurityArgs(
            protocol="PLAINTEXT",
        ),
        config={
            "auto.offset.reset": "latest",
        },
        bootstrap_servers="localhost:9091,localhost:9092")
    
    package main
    
    import (
    	"github.com/pulumi/pulumi-mongodbatlas/sdk/v3/go/mongodbatlas"
    	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
    )
    
    func main() {
    	pulumi.Run(func(ctx *pulumi.Context) error {
    		_, err := mongodbatlas.NewStreamConnection(ctx, "test", &mongodbatlas.StreamConnectionArgs{
    			ProjectId:      pulumi.Any(projectId),
    			InstanceName:   pulumi.String("NewInstance"),
    			ConnectionName: pulumi.String("KafkaConnection"),
    			Type:           pulumi.String("Kafka"),
    			Authentication: &mongodbatlas.StreamConnectionAuthenticationArgs{
    				Mechanism: pulumi.String("SCRAM-256"),
    				Username:  pulumi.String("user"),
    				Password:  pulumi.String("somepassword"),
    			},
    			Security: &mongodbatlas.StreamConnectionSecurityArgs{
    				Protocol: pulumi.String("PLAINTEXT"),
    			},
    			Config: pulumi.StringMap{
    				"auto.offset.reset": pulumi.String("latest"),
    			},
    			BootstrapServers: pulumi.String("localhost:9091,localhost:9092"),
    		})
    		if err != nil {
    			return err
    		}
    		return nil
    	})
    }
    
    using System.Collections.Generic;
    using System.Linq;
    using Pulumi;
    using Mongodbatlas = Pulumi.Mongodbatlas;
    
    return await Deployment.RunAsync(() => 
    {
        var test = new Mongodbatlas.StreamConnection("test", new()
        {
            ProjectId = projectId,
            InstanceName = "NewInstance",
            ConnectionName = "KafkaConnection",
            Type = "Kafka",
            Authentication = new Mongodbatlas.Inputs.StreamConnectionAuthenticationArgs
            {
                Mechanism = "SCRAM-256",
                Username = "user",
                Password = "somepassword",
            },
            Security = new Mongodbatlas.Inputs.StreamConnectionSecurityArgs
            {
                Protocol = "PLAINTEXT",
            },
            Config = 
            {
                { "auto.offset.reset", "latest" },
            },
            BootstrapServers = "localhost:9091,localhost:9092",
        });
    
    });
    
    package generated_program;
    
    import com.pulumi.Context;
    import com.pulumi.Pulumi;
    import com.pulumi.core.Output;
    import com.pulumi.mongodbatlas.StreamConnection;
    import com.pulumi.mongodbatlas.StreamConnectionArgs;
    import com.pulumi.mongodbatlas.inputs.StreamConnectionAuthenticationArgs;
    import com.pulumi.mongodbatlas.inputs.StreamConnectionSecurityArgs;
    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 test = new StreamConnection("test", StreamConnectionArgs.builder()
                .projectId(projectId)
                .instanceName("NewInstance")
                .connectionName("KafkaConnection")
                .type("Kafka")
                .authentication(StreamConnectionAuthenticationArgs.builder()
                    .mechanism("SCRAM-256")
                    .username("user")
                    .password("somepassword")
                    .build())
                .security(StreamConnectionSecurityArgs.builder()
                    .protocol("PLAINTEXT")
                    .build())
                .config(Map.of("auto.offset.reset", "latest"))
                .bootstrapServers("localhost:9091,localhost:9092")
                .build());
    
        }
    }
    
    resources:
      test:
        type: mongodbatlas:StreamConnection
        properties:
          projectId: ${projectId}
          instanceName: NewInstance
          connectionName: KafkaConnection
          type: Kafka
          authentication:
            mechanism: SCRAM-256
            username: user
            password: somepassword
          security:
            protocol: PLAINTEXT
          config:
            auto.offset.reset: latest
          bootstrapServers: localhost:9091,localhost:9092
    

    Example Kafka SSL Connection

    Coming soon!
    
    Coming soon!
    
    Coming soon!
    
    Coming soon!
    
    package generated_program;
    
    import com.pulumi.Context;
    import com.pulumi.Pulumi;
    import com.pulumi.core.Output;
    import com.pulumi.mongodbatlas.StreamConnection;
    import com.pulumi.mongodbatlas.StreamConnectionArgs;
    import com.pulumi.mongodbatlas.inputs.StreamConnectionAuthenticationArgs;
    import com.pulumi.mongodbatlas.inputs.StreamConnectionSecurityArgs;
    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 test = new StreamConnection("test", StreamConnectionArgs.builder()
                .projectId(projectId)
                .instanceName("NewInstance")
                .connectionName("KafkaConnection")
                .type("Kafka")
                .authentication(StreamConnectionAuthenticationArgs.builder()
                    .mechanism("PLAIN")
                    .username("user")
                    .password("somepassword")
                    .build())
                .security(StreamConnectionSecurityArgs.builder()
                    .protocol("SSL")
                    .broker_public_certificate("-----BEGIN CERTIFICATE-----<CONTENT>-----END CERTIFICATE-----")
                    .build())
                .config(Map.of("auto.offset.reset", "latest"))
                .bootstrapServers("localhost:9091,localhost:9092")
                .build());
    
        }
    }
    
    resources:
      test:
        type: mongodbatlas:StreamConnection
        properties:
          projectId: ${projectId}
          instanceName: NewInstance
          connectionName: KafkaConnection
          type: Kafka
          authentication:
            mechanism: PLAIN
            username: user
            password: somepassword
          security:
            protocol: SSL
            broker_public_certificate: '-----BEGIN CERTIFICATE-----<CONTENT>-----END CERTIFICATE-----'
          config:
            auto.offset.reset: latest
          bootstrapServers: localhost:9091,localhost:9092
    

    Create StreamConnection Resource

    Resources are created with functions called constructors. To learn more about declaring and configuring resources, see Resources.

    Constructor syntax

    new StreamConnection(name: string, args: StreamConnectionArgs, opts?: CustomResourceOptions);
    @overload
    def StreamConnection(resource_name: str,
                         args: StreamConnectionArgs,
                         opts: Optional[ResourceOptions] = None)
    
    @overload
    def StreamConnection(resource_name: str,
                         opts: Optional[ResourceOptions] = None,
                         connection_name: Optional[str] = None,
                         instance_name: Optional[str] = None,
                         project_id: Optional[str] = None,
                         type: Optional[str] = None,
                         authentication: Optional[StreamConnectionAuthenticationArgs] = None,
                         bootstrap_servers: Optional[str] = None,
                         cluster_name: Optional[str] = None,
                         config: Optional[Mapping[str, str]] = None,
                         db_role_to_execute: Optional[StreamConnectionDbRoleToExecuteArgs] = None,
                         security: Optional[StreamConnectionSecurityArgs] = None)
    func NewStreamConnection(ctx *Context, name string, args StreamConnectionArgs, opts ...ResourceOption) (*StreamConnection, error)
    public StreamConnection(string name, StreamConnectionArgs args, CustomResourceOptions? opts = null)
    public StreamConnection(String name, StreamConnectionArgs args)
    public StreamConnection(String name, StreamConnectionArgs args, CustomResourceOptions options)
    
    type: mongodbatlas:StreamConnection
    properties: # The arguments to resource properties.
    options: # Bag of options to control resource's behavior.
    
    

    Parameters

    name string
    The unique name of the resource.
    args StreamConnectionArgs
    The arguments to resource properties.
    opts CustomResourceOptions
    Bag of options to control resource's behavior.
    resource_name str
    The unique name of the resource.
    args StreamConnectionArgs
    The arguments to resource properties.
    opts ResourceOptions
    Bag of options to control resource's behavior.
    ctx Context
    Context object for the current deployment.
    name string
    The unique name of the resource.
    args StreamConnectionArgs
    The arguments to resource properties.
    opts ResourceOption
    Bag of options to control resource's behavior.
    name string
    The unique name of the resource.
    args StreamConnectionArgs
    The arguments to resource properties.
    opts CustomResourceOptions
    Bag of options to control resource's behavior.
    name String
    The unique name of the resource.
    args StreamConnectionArgs
    The arguments to resource properties.
    options CustomResourceOptions
    Bag of options to control resource's behavior.

    Constructor example

    The following reference example uses placeholder values for all input properties.

    var streamConnectionResource = new Mongodbatlas.StreamConnection("streamConnectionResource", new()
    {
        ConnectionName = "string",
        InstanceName = "string",
        ProjectId = "string",
        Type = "string",
        Authentication = new Mongodbatlas.Inputs.StreamConnectionAuthenticationArgs
        {
            Mechanism = "string",
            Password = "string",
            Username = "string",
        },
        BootstrapServers = "string",
        ClusterName = "string",
        Config = 
        {
            { "string", "string" },
        },
        DbRoleToExecute = new Mongodbatlas.Inputs.StreamConnectionDbRoleToExecuteArgs
        {
            Role = "string",
            Type = "string",
        },
        Security = new Mongodbatlas.Inputs.StreamConnectionSecurityArgs
        {
            BrokerPublicCertificate = "string",
            Protocol = "string",
        },
    });
    
    example, err := mongodbatlas.NewStreamConnection(ctx, "streamConnectionResource", &mongodbatlas.StreamConnectionArgs{
    	ConnectionName: pulumi.String("string"),
    	InstanceName:   pulumi.String("string"),
    	ProjectId:      pulumi.String("string"),
    	Type:           pulumi.String("string"),
    	Authentication: &mongodbatlas.StreamConnectionAuthenticationArgs{
    		Mechanism: pulumi.String("string"),
    		Password:  pulumi.String("string"),
    		Username:  pulumi.String("string"),
    	},
    	BootstrapServers: pulumi.String("string"),
    	ClusterName:      pulumi.String("string"),
    	Config: pulumi.StringMap{
    		"string": pulumi.String("string"),
    	},
    	DbRoleToExecute: &mongodbatlas.StreamConnectionDbRoleToExecuteArgs{
    		Role: pulumi.String("string"),
    		Type: pulumi.String("string"),
    	},
    	Security: &mongodbatlas.StreamConnectionSecurityArgs{
    		BrokerPublicCertificate: pulumi.String("string"),
    		Protocol:                pulumi.String("string"),
    	},
    })
    
    var streamConnectionResource = new StreamConnection("streamConnectionResource", StreamConnectionArgs.builder()
        .connectionName("string")
        .instanceName("string")
        .projectId("string")
        .type("string")
        .authentication(StreamConnectionAuthenticationArgs.builder()
            .mechanism("string")
            .password("string")
            .username("string")
            .build())
        .bootstrapServers("string")
        .clusterName("string")
        .config(Map.of("string", "string"))
        .dbRoleToExecute(StreamConnectionDbRoleToExecuteArgs.builder()
            .role("string")
            .type("string")
            .build())
        .security(StreamConnectionSecurityArgs.builder()
            .brokerPublicCertificate("string")
            .protocol("string")
            .build())
        .build());
    
    stream_connection_resource = mongodbatlas.StreamConnection("streamConnectionResource",
        connection_name="string",
        instance_name="string",
        project_id="string",
        type="string",
        authentication=mongodbatlas.StreamConnectionAuthenticationArgs(
            mechanism="string",
            password="string",
            username="string",
        ),
        bootstrap_servers="string",
        cluster_name="string",
        config={
            "string": "string",
        },
        db_role_to_execute=mongodbatlas.StreamConnectionDbRoleToExecuteArgs(
            role="string",
            type="string",
        ),
        security=mongodbatlas.StreamConnectionSecurityArgs(
            broker_public_certificate="string",
            protocol="string",
        ))
    
    const streamConnectionResource = new mongodbatlas.StreamConnection("streamConnectionResource", {
        connectionName: "string",
        instanceName: "string",
        projectId: "string",
        type: "string",
        authentication: {
            mechanism: "string",
            password: "string",
            username: "string",
        },
        bootstrapServers: "string",
        clusterName: "string",
        config: {
            string: "string",
        },
        dbRoleToExecute: {
            role: "string",
            type: "string",
        },
        security: {
            brokerPublicCertificate: "string",
            protocol: "string",
        },
    });
    
    type: mongodbatlas:StreamConnection
    properties:
        authentication:
            mechanism: string
            password: string
            username: string
        bootstrapServers: string
        clusterName: string
        config:
            string: string
        connectionName: string
        dbRoleToExecute:
            role: string
            type: string
        instanceName: string
        projectId: string
        security:
            brokerPublicCertificate: string
            protocol: string
        type: string
    

    StreamConnection Resource Properties

    To learn more about resource properties and how to use them, see Inputs and Outputs in the Architecture and Concepts docs.

    Inputs

    The StreamConnection resource accepts the following input properties:

    ConnectionName string
    Human-readable label that identifies the stream connection. In the case of the Sample type, this is the name of the sample source.
    InstanceName string
    Human-readable label that identifies the stream instance.
    ProjectId string
    Unique 24-hexadecimal digit string that identifies your project.
    Type string
    Type of connection. Can be either Cluster, Kafka or Sample.
    Authentication StreamConnectionAuthentication
    BootstrapServers string
    ClusterName string
    Config Dictionary<string, string>
    DbRoleToExecute StreamConnectionDbRoleToExecute
    Security StreamConnectionSecurity
    ConnectionName string
    Human-readable label that identifies the stream connection. In the case of the Sample type, this is the name of the sample source.
    InstanceName string
    Human-readable label that identifies the stream instance.
    ProjectId string
    Unique 24-hexadecimal digit string that identifies your project.
    Type string
    Type of connection. Can be either Cluster, Kafka or Sample.
    Authentication StreamConnectionAuthenticationArgs
    BootstrapServers string
    ClusterName string
    Config map[string]string
    DbRoleToExecute StreamConnectionDbRoleToExecuteArgs
    Security StreamConnectionSecurityArgs
    connectionName String
    Human-readable label that identifies the stream connection. In the case of the Sample type, this is the name of the sample source.
    instanceName String
    Human-readable label that identifies the stream instance.
    projectId String
    Unique 24-hexadecimal digit string that identifies your project.
    type String
    Type of connection. Can be either Cluster, Kafka or Sample.
    authentication StreamConnectionAuthentication
    bootstrapServers String
    clusterName String
    config Map<String,String>
    dbRoleToExecute StreamConnectionDbRoleToExecute
    security StreamConnectionSecurity
    connectionName string
    Human-readable label that identifies the stream connection. In the case of the Sample type, this is the name of the sample source.
    instanceName string
    Human-readable label that identifies the stream instance.
    projectId string
    Unique 24-hexadecimal digit string that identifies your project.
    type string
    Type of connection. Can be either Cluster, Kafka or Sample.
    authentication StreamConnectionAuthentication
    bootstrapServers string
    clusterName string
    config {[key: string]: string}
    dbRoleToExecute StreamConnectionDbRoleToExecute
    security StreamConnectionSecurity
    connection_name str
    Human-readable label that identifies the stream connection. In the case of the Sample type, this is the name of the sample source.
    instance_name str
    Human-readable label that identifies the stream instance.
    project_id str
    Unique 24-hexadecimal digit string that identifies your project.
    type str
    Type of connection. Can be either Cluster, Kafka or Sample.
    authentication StreamConnectionAuthenticationArgs
    bootstrap_servers str
    cluster_name str
    config Mapping[str, str]
    db_role_to_execute StreamConnectionDbRoleToExecuteArgs
    security StreamConnectionSecurityArgs
    connectionName String
    Human-readable label that identifies the stream connection. In the case of the Sample type, this is the name of the sample source.
    instanceName String
    Human-readable label that identifies the stream instance.
    projectId String
    Unique 24-hexadecimal digit string that identifies your project.
    type String
    Type of connection. Can be either Cluster, Kafka or Sample.
    authentication Property Map
    bootstrapServers String
    clusterName String
    config Map<String>
    dbRoleToExecute Property Map
    security Property Map

    Outputs

    All input properties are implicitly available as output properties. Additionally, the StreamConnection resource produces the following output properties:

    Id string
    The provider-assigned unique ID for this managed resource.
    Id string
    The provider-assigned unique ID for this managed resource.
    id String
    The provider-assigned unique ID for this managed resource.
    id string
    The provider-assigned unique ID for this managed resource.
    id str
    The provider-assigned unique ID for this managed resource.
    id String
    The provider-assigned unique ID for this managed resource.

    Look up Existing StreamConnection Resource

    Get an existing StreamConnection resource’s state with the given name, ID, and optional extra properties used to qualify the lookup.

    public static get(name: string, id: Input<ID>, state?: StreamConnectionState, opts?: CustomResourceOptions): StreamConnection
    @staticmethod
    def get(resource_name: str,
            id: str,
            opts: Optional[ResourceOptions] = None,
            authentication: Optional[StreamConnectionAuthenticationArgs] = None,
            bootstrap_servers: Optional[str] = None,
            cluster_name: Optional[str] = None,
            config: Optional[Mapping[str, str]] = None,
            connection_name: Optional[str] = None,
            db_role_to_execute: Optional[StreamConnectionDbRoleToExecuteArgs] = None,
            instance_name: Optional[str] = None,
            project_id: Optional[str] = None,
            security: Optional[StreamConnectionSecurityArgs] = None,
            type: Optional[str] = None) -> StreamConnection
    func GetStreamConnection(ctx *Context, name string, id IDInput, state *StreamConnectionState, opts ...ResourceOption) (*StreamConnection, error)
    public static StreamConnection Get(string name, Input<string> id, StreamConnectionState? state, CustomResourceOptions? opts = null)
    public static StreamConnection get(String name, Output<String> id, StreamConnectionState state, CustomResourceOptions options)
    Resource lookup is not supported in YAML
    name
    The unique name of the resulting resource.
    id
    The unique provider ID of the resource to lookup.
    state
    Any extra arguments used during the lookup.
    opts
    A bag of options that control this resource's behavior.
    resource_name
    The unique name of the resulting resource.
    id
    The unique provider ID of the resource to lookup.
    name
    The unique name of the resulting resource.
    id
    The unique provider ID of the resource to lookup.
    state
    Any extra arguments used during the lookup.
    opts
    A bag of options that control this resource's behavior.
    name
    The unique name of the resulting resource.
    id
    The unique provider ID of the resource to lookup.
    state
    Any extra arguments used during the lookup.
    opts
    A bag of options that control this resource's behavior.
    name
    The unique name of the resulting resource.
    id
    The unique provider ID of the resource to lookup.
    state
    Any extra arguments used during the lookup.
    opts
    A bag of options that control this resource's behavior.
    The following state arguments are supported:
    Authentication StreamConnectionAuthentication
    BootstrapServers string
    ClusterName string
    Config Dictionary<string, string>
    ConnectionName string
    Human-readable label that identifies the stream connection. In the case of the Sample type, this is the name of the sample source.
    DbRoleToExecute StreamConnectionDbRoleToExecute
    InstanceName string
    Human-readable label that identifies the stream instance.
    ProjectId string
    Unique 24-hexadecimal digit string that identifies your project.
    Security StreamConnectionSecurity
    Type string
    Type of connection. Can be either Cluster, Kafka or Sample.
    Authentication StreamConnectionAuthenticationArgs
    BootstrapServers string
    ClusterName string
    Config map[string]string
    ConnectionName string
    Human-readable label that identifies the stream connection. In the case of the Sample type, this is the name of the sample source.
    DbRoleToExecute StreamConnectionDbRoleToExecuteArgs
    InstanceName string
    Human-readable label that identifies the stream instance.
    ProjectId string
    Unique 24-hexadecimal digit string that identifies your project.
    Security StreamConnectionSecurityArgs
    Type string
    Type of connection. Can be either Cluster, Kafka or Sample.
    authentication StreamConnectionAuthentication
    bootstrapServers String
    clusterName String
    config Map<String,String>
    connectionName String
    Human-readable label that identifies the stream connection. In the case of the Sample type, this is the name of the sample source.
    dbRoleToExecute StreamConnectionDbRoleToExecute
    instanceName String
    Human-readable label that identifies the stream instance.
    projectId String
    Unique 24-hexadecimal digit string that identifies your project.
    security StreamConnectionSecurity
    type String
    Type of connection. Can be either Cluster, Kafka or Sample.
    authentication StreamConnectionAuthentication
    bootstrapServers string
    clusterName string
    config {[key: string]: string}
    connectionName string
    Human-readable label that identifies the stream connection. In the case of the Sample type, this is the name of the sample source.
    dbRoleToExecute StreamConnectionDbRoleToExecute
    instanceName string
    Human-readable label that identifies the stream instance.
    projectId string
    Unique 24-hexadecimal digit string that identifies your project.
    security StreamConnectionSecurity
    type string
    Type of connection. Can be either Cluster, Kafka or Sample.
    authentication StreamConnectionAuthenticationArgs
    bootstrap_servers str
    cluster_name str
    config Mapping[str, str]
    connection_name str
    Human-readable label that identifies the stream connection. In the case of the Sample type, this is the name of the sample source.
    db_role_to_execute StreamConnectionDbRoleToExecuteArgs
    instance_name str
    Human-readable label that identifies the stream instance.
    project_id str
    Unique 24-hexadecimal digit string that identifies your project.
    security StreamConnectionSecurityArgs
    type str
    Type of connection. Can be either Cluster, Kafka or Sample.
    authentication Property Map
    bootstrapServers String
    clusterName String
    config Map<String>
    connectionName String
    Human-readable label that identifies the stream connection. In the case of the Sample type, this is the name of the sample source.
    dbRoleToExecute Property Map
    instanceName String
    Human-readable label that identifies the stream instance.
    projectId String
    Unique 24-hexadecimal digit string that identifies your project.
    security Property Map
    type String
    Type of connection. Can be either Cluster, Kafka or Sample.

    Supporting Types

    StreamConnectionAuthentication, StreamConnectionAuthenticationArgs

    Mechanism string
    Style of authentication. Can be one of PLAIN, SCRAM-256, or SCRAM-512.
    Password string
    Password of the account to connect to the Kafka cluster.
    Username string
    Username of the account to connect to the Kafka cluster.
    Mechanism string
    Style of authentication. Can be one of PLAIN, SCRAM-256, or SCRAM-512.
    Password string
    Password of the account to connect to the Kafka cluster.
    Username string
    Username of the account to connect to the Kafka cluster.
    mechanism String
    Style of authentication. Can be one of PLAIN, SCRAM-256, or SCRAM-512.
    password String
    Password of the account to connect to the Kafka cluster.
    username String
    Username of the account to connect to the Kafka cluster.
    mechanism string
    Style of authentication. Can be one of PLAIN, SCRAM-256, or SCRAM-512.
    password string
    Password of the account to connect to the Kafka cluster.
    username string
    Username of the account to connect to the Kafka cluster.
    mechanism str
    Style of authentication. Can be one of PLAIN, SCRAM-256, or SCRAM-512.
    password str
    Password of the account to connect to the Kafka cluster.
    username str
    Username of the account to connect to the Kafka cluster.
    mechanism String
    Style of authentication. Can be one of PLAIN, SCRAM-256, or SCRAM-512.
    password String
    Password of the account to connect to the Kafka cluster.
    username String
    Username of the account to connect to the Kafka cluster.

    StreamConnectionDbRoleToExecute, StreamConnectionDbRoleToExecuteArgs

    Role string
    Type string
    Type of connection. Can be either Cluster, Kafka or Sample.
    Role string
    Type string
    Type of connection. Can be either Cluster, Kafka or Sample.
    role String
    type String
    Type of connection. Can be either Cluster, Kafka or Sample.
    role string
    type string
    Type of connection. Can be either Cluster, Kafka or Sample.
    role str
    type str
    Type of connection. Can be either Cluster, Kafka or Sample.
    role String
    type String
    Type of connection. Can be either Cluster, Kafka or Sample.

    StreamConnectionSecurity, StreamConnectionSecurityArgs

    BrokerPublicCertificate string
    A trusted, public x509 certificate for connecting to Kafka over SSL. String value of the certificate must be defined in the attribute.
    Protocol string
    Describes the transport type. Can be either PLAINTEXT or SSL.
    BrokerPublicCertificate string
    A trusted, public x509 certificate for connecting to Kafka over SSL. String value of the certificate must be defined in the attribute.
    Protocol string
    Describes the transport type. Can be either PLAINTEXT or SSL.
    brokerPublicCertificate String
    A trusted, public x509 certificate for connecting to Kafka over SSL. String value of the certificate must be defined in the attribute.
    protocol String
    Describes the transport type. Can be either PLAINTEXT or SSL.
    brokerPublicCertificate string
    A trusted, public x509 certificate for connecting to Kafka over SSL. String value of the certificate must be defined in the attribute.
    protocol string
    Describes the transport type. Can be either PLAINTEXT or SSL.
    broker_public_certificate str
    A trusted, public x509 certificate for connecting to Kafka over SSL. String value of the certificate must be defined in the attribute.
    protocol str
    Describes the transport type. Can be either PLAINTEXT or SSL.
    brokerPublicCertificate String
    A trusted, public x509 certificate for connecting to Kafka over SSL. String value of the certificate must be defined in the attribute.
    protocol String
    Describes the transport type. Can be either PLAINTEXT or SSL.

    Import

    You can import a stream connection resource using the instance name, project ID, and connection name. The format must be INSTANCE_NAME-PROJECT_ID-CONNECTION_NAME. For example:

    $ pulumi import mongodbatlas:index/streamConnection:StreamConnection test "DefaultInstance-12251446ae5f3f6ec7968b13-NewConnection"
    

    To learn more, see: MongoDB Atlas API - Stream Connection Documentation. The Terraform Provider Examples Section also contains details on the overall support for Atlas Streams Processing in Terraform.

    To learn more about importing existing cloud resources, see Importing resources.

    Package Details

    Repository
    MongoDB Atlas pulumi/pulumi-mongodbatlas
    License
    Apache-2.0
    Notes
    This Pulumi package is based on the mongodbatlas Terraform Provider.
    mongodbatlas logo
    MongoDB Atlas v3.16.2 published on Friday, Jun 21, 2024 by Pulumi