MongoDB Atlas v3.30.0 published on Friday, Mar 21, 2025 by Pulumi
mongodbatlas.getStreamConnection
Explore with Pulumi AI
# Data Source: mongodbatlas.StreamConnection
mongodbatlas.StreamConnection describes a stream connection.
Example Usage
import * as pulumi from "@pulumi/pulumi";
import * as mongodbatlas from "@pulumi/mongodbatlas";
const example = mongodbatlas.getStreamConnection({
    projectId: "<PROJECT_ID>",
    instanceName: "<INSTANCE_NAME>",
    connectionName: "<CONNECTION_NAME>",
});
import pulumi
import pulumi_mongodbatlas as mongodbatlas
example = mongodbatlas.get_stream_connection(project_id="<PROJECT_ID>",
    instance_name="<INSTANCE_NAME>",
    connection_name="<CONNECTION_NAME>")
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.LookupStreamConnection(ctx, &mongodbatlas.LookupStreamConnectionArgs{
			ProjectId:      "<PROJECT_ID>",
			InstanceName:   "<INSTANCE_NAME>",
			ConnectionName: "<CONNECTION_NAME>",
		}, nil)
		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 example = Mongodbatlas.GetStreamConnection.Invoke(new()
    {
        ProjectId = "<PROJECT_ID>",
        InstanceName = "<INSTANCE_NAME>",
        ConnectionName = "<CONNECTION_NAME>",
    });
});
package generated_program;
import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.mongodbatlas.MongodbatlasFunctions;
import com.pulumi.mongodbatlas.inputs.GetStreamConnectionArgs;
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 example = MongodbatlasFunctions.getStreamConnection(GetStreamConnectionArgs.builder()
            .projectId("<PROJECT_ID>")
            .instanceName("<INSTANCE_NAME>")
            .connectionName("<CONNECTION_NAME>")
            .build());
    }
}
variables:
  example:
    fn::invoke:
      function: mongodbatlas:getStreamConnection
      arguments:
        projectId: <PROJECT_ID>
        instanceName: <INSTANCE_NAME>
        connectionName: <CONNECTION_NAME>
Using getStreamConnection
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 getStreamConnection(args: GetStreamConnectionArgs, opts?: InvokeOptions): Promise<GetStreamConnectionResult>
function getStreamConnectionOutput(args: GetStreamConnectionOutputArgs, opts?: InvokeOptions): Output<GetStreamConnectionResult>def get_stream_connection(connection_name: Optional[str] = None,
                          instance_name: Optional[str] = None,
                          project_id: Optional[str] = None,
                          opts: Optional[InvokeOptions] = None) -> GetStreamConnectionResult
def get_stream_connection_output(connection_name: Optional[pulumi.Input[str]] = None,
                          instance_name: Optional[pulumi.Input[str]] = None,
                          project_id: Optional[pulumi.Input[str]] = None,
                          opts: Optional[InvokeOptions] = None) -> Output[GetStreamConnectionResult]func LookupStreamConnection(ctx *Context, args *LookupStreamConnectionArgs, opts ...InvokeOption) (*LookupStreamConnectionResult, error)
func LookupStreamConnectionOutput(ctx *Context, args *LookupStreamConnectionOutputArgs, opts ...InvokeOption) LookupStreamConnectionResultOutput> Note: This function is named LookupStreamConnection in the Go SDK.
public static class GetStreamConnection 
{
    public static Task<GetStreamConnectionResult> InvokeAsync(GetStreamConnectionArgs args, InvokeOptions? opts = null)
    public static Output<GetStreamConnectionResult> Invoke(GetStreamConnectionInvokeArgs args, InvokeOptions? opts = null)
}public static CompletableFuture<GetStreamConnectionResult> getStreamConnection(GetStreamConnectionArgs args, InvokeOptions options)
public static Output<GetStreamConnectionResult> getStreamConnection(GetStreamConnectionArgs args, InvokeOptions options)
fn::invoke:
  function: mongodbatlas:index/getStreamConnection:getStreamConnection
  arguments:
    # arguments dictionaryThe following arguments are supported:
- 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.
- 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.
- 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.
- 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.
- 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.
- 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.
getStreamConnection Result
The following output properties are available:
- Authentication
GetStream Connection Authentication 
- User credentials required to connect to a Kafka cluster. Includes the authentication type, as well as the parameters for that authentication mode. See authentication.
- Aws
GetStream Connection Aws 
- The configuration for AWS Lambda connection. See AWS
- BootstrapServers string
- Comma separated list of server addresses.
- ClusterName string
- Name of the cluster configured for this connection.
- Config Dictionary<string, string>
- A map of Kafka key-value pairs for optional configuration. This is a flat object, and keys can have '.' characters.
- ConnectionName string
- DbRole GetTo Execute Stream Connection Db Role To Execute 
- The name of a Built in or Custom DB Role to connect to an Atlas Cluster. See DBRoleToExecute.
- Headers Dictionary<string, string>
- A map of key-value pairs for optional headers.
- Id string
- InstanceName string
- Networking
GetStream Connection Networking 
- Networking Access Type can either be PUBLIC(default) orVPC. See networking.
- ProjectId string
- Security
GetStream Connection Security 
- Properties for the secure transport connection to Kafka. For SSL, this can include the trusted certificate to use. See security.
- Type string
- Selected networking type. Either PUBLIC,VPCorPRIVATE_LINK. Defaults toPUBLIC.
- Url string
- URL of the HTTPs endpoint that will be used for creating a connection.
- Authentication
GetStream Connection Authentication 
- User credentials required to connect to a Kafka cluster. Includes the authentication type, as well as the parameters for that authentication mode. See authentication.
- Aws
GetStream Connection Aws 
- The configuration for AWS Lambda connection. See AWS
- BootstrapServers string
- Comma separated list of server addresses.
- ClusterName string
- Name of the cluster configured for this connection.
- Config map[string]string
- A map of Kafka key-value pairs for optional configuration. This is a flat object, and keys can have '.' characters.
- ConnectionName string
- DbRole GetTo Execute Stream Connection Db Role To Execute 
- The name of a Built in or Custom DB Role to connect to an Atlas Cluster. See DBRoleToExecute.
- Headers map[string]string
- A map of key-value pairs for optional headers.
- Id string
- InstanceName string
- Networking
GetStream Connection Networking 
- Networking Access Type can either be PUBLIC(default) orVPC. See networking.
- ProjectId string
- Security
GetStream Connection Security 
- Properties for the secure transport connection to Kafka. For SSL, this can include the trusted certificate to use. See security.
- Type string
- Selected networking type. Either PUBLIC,VPCorPRIVATE_LINK. Defaults toPUBLIC.
- Url string
- URL of the HTTPs endpoint that will be used for creating a connection.
- authentication
GetStream Connection Authentication 
- User credentials required to connect to a Kafka cluster. Includes the authentication type, as well as the parameters for that authentication mode. See authentication.
- aws
GetStream Connection Aws 
- The configuration for AWS Lambda connection. See AWS
- bootstrapServers String
- Comma separated list of server addresses.
- clusterName String
- Name of the cluster configured for this connection.
- config Map<String,String>
- A map of Kafka key-value pairs for optional configuration. This is a flat object, and keys can have '.' characters.
- connectionName String
- dbRole GetTo Execute Stream Connection Db Role To Execute 
- The name of a Built in or Custom DB Role to connect to an Atlas Cluster. See DBRoleToExecute.
- headers Map<String,String>
- A map of key-value pairs for optional headers.
- id String
- instanceName String
- networking
GetStream Connection Networking 
- Networking Access Type can either be PUBLIC(default) orVPC. See networking.
- projectId String
- security
GetStream Connection Security 
- Properties for the secure transport connection to Kafka. For SSL, this can include the trusted certificate to use. See security.
- type String
- Selected networking type. Either PUBLIC,VPCorPRIVATE_LINK. Defaults toPUBLIC.
- url String
- URL of the HTTPs endpoint that will be used for creating a connection.
- authentication
GetStream Connection Authentication 
- User credentials required to connect to a Kafka cluster. Includes the authentication type, as well as the parameters for that authentication mode. See authentication.
- aws
GetStream Connection Aws 
- The configuration for AWS Lambda connection. See AWS
- bootstrapServers string
- Comma separated list of server addresses.
- clusterName string
- Name of the cluster configured for this connection.
- config {[key: string]: string}
- A map of Kafka key-value pairs for optional configuration. This is a flat object, and keys can have '.' characters.
- connectionName string
- dbRole GetTo Execute Stream Connection Db Role To Execute 
- The name of a Built in or Custom DB Role to connect to an Atlas Cluster. See DBRoleToExecute.
- headers {[key: string]: string}
- A map of key-value pairs for optional headers.
- id string
- instanceName string
- networking
GetStream Connection Networking 
- Networking Access Type can either be PUBLIC(default) orVPC. See networking.
- projectId string
- security
GetStream Connection Security 
- Properties for the secure transport connection to Kafka. For SSL, this can include the trusted certificate to use. See security.
- type string
- Selected networking type. Either PUBLIC,VPCorPRIVATE_LINK. Defaults toPUBLIC.
- url string
- URL of the HTTPs endpoint that will be used for creating a connection.
- authentication
GetStream Connection Authentication 
- User credentials required to connect to a Kafka cluster. Includes the authentication type, as well as the parameters for that authentication mode. See authentication.
- aws
GetStream Connection Aws 
- The configuration for AWS Lambda connection. See AWS
- bootstrap_servers str
- Comma separated list of server addresses.
- cluster_name str
- Name of the cluster configured for this connection.
- config Mapping[str, str]
- A map of Kafka key-value pairs for optional configuration. This is a flat object, and keys can have '.' characters.
- connection_name str
- db_role_ Getto_ execute Stream Connection Db Role To Execute 
- The name of a Built in or Custom DB Role to connect to an Atlas Cluster. See DBRoleToExecute.
- headers Mapping[str, str]
- A map of key-value pairs for optional headers.
- id str
- instance_name str
- networking
GetStream Connection Networking 
- Networking Access Type can either be PUBLIC(default) orVPC. See networking.
- project_id str
- security
GetStream Connection Security 
- Properties for the secure transport connection to Kafka. For SSL, this can include the trusted certificate to use. See security.
- type str
- Selected networking type. Either PUBLIC,VPCorPRIVATE_LINK. Defaults toPUBLIC.
- url str
- URL of the HTTPs endpoint that will be used for creating a connection.
- authentication Property Map
- User credentials required to connect to a Kafka cluster. Includes the authentication type, as well as the parameters for that authentication mode. See authentication.
- aws Property Map
- The configuration for AWS Lambda connection. See AWS
- bootstrapServers String
- Comma separated list of server addresses.
- clusterName String
- Name of the cluster configured for this connection.
- config Map<String>
- A map of Kafka key-value pairs for optional configuration. This is a flat object, and keys can have '.' characters.
- connectionName String
- dbRole Property MapTo Execute 
- The name of a Built in or Custom DB Role to connect to an Atlas Cluster. See DBRoleToExecute.
- headers Map<String>
- A map of key-value pairs for optional headers.
- id String
- instanceName String
- networking Property Map
- Networking Access Type can either be PUBLIC(default) orVPC. See networking.
- projectId String
- security Property Map
- Properties for the secure transport connection to Kafka. For SSL, this can include the trusted certificate to use. See security.
- type String
- Selected networking type. Either PUBLIC,VPCorPRIVATE_LINK. Defaults toPUBLIC.
- url String
- URL of the HTTPs endpoint that will be used for creating a connection.
Supporting Types
GetStreamConnectionAuthentication   
GetStreamConnectionAws   
- RoleArn string
- Amazon Resource Name (ARN) that identifies the Amazon Web Services (AWS) Identity and Access Management (IAM) role that MongoDB Cloud assumes when it accesses resources in your AWS account.
- RoleArn string
- Amazon Resource Name (ARN) that identifies the Amazon Web Services (AWS) Identity and Access Management (IAM) role that MongoDB Cloud assumes when it accesses resources in your AWS account.
- roleArn String
- Amazon Resource Name (ARN) that identifies the Amazon Web Services (AWS) Identity and Access Management (IAM) role that MongoDB Cloud assumes when it accesses resources in your AWS account.
- roleArn string
- Amazon Resource Name (ARN) that identifies the Amazon Web Services (AWS) Identity and Access Management (IAM) role that MongoDB Cloud assumes when it accesses resources in your AWS account.
- role_arn str
- Amazon Resource Name (ARN) that identifies the Amazon Web Services (AWS) Identity and Access Management (IAM) role that MongoDB Cloud assumes when it accesses resources in your AWS account.
- roleArn String
- Amazon Resource Name (ARN) that identifies the Amazon Web Services (AWS) Identity and Access Management (IAM) role that MongoDB Cloud assumes when it accesses resources in your AWS account.
GetStreamConnectionDbRoleToExecute      
GetStreamConnectionNetworking   
- Access
GetStream Connection Networking Access 
- Information about the networking access. See access.
- Access
GetStream Connection Networking Access 
- Information about the networking access. See access.
- access
GetStream Connection Networking Access 
- Information about the networking access. See access.
- access
GetStream Connection Networking Access 
- Information about the networking access. See access.
- access
GetStream Connection Networking Access 
- Information about the networking access. See access.
- access Property Map
- Information about the networking access. See access.
GetStreamConnectionNetworkingAccess    
- ConnectionId string
- Id of the Private Link connection when type is PRIVATE_LINK.
- Type string
- Selected networking type. Either PUBLIC,VPCorPRIVATE_LINK. Defaults toPUBLIC.
- ConnectionId string
- Id of the Private Link connection when type is PRIVATE_LINK.
- Type string
- Selected networking type. Either PUBLIC,VPCorPRIVATE_LINK. Defaults toPUBLIC.
- connectionId String
- Id of the Private Link connection when type is PRIVATE_LINK.
- type String
- Selected networking type. Either PUBLIC,VPCorPRIVATE_LINK. Defaults toPUBLIC.
- connectionId string
- Id of the Private Link connection when type is PRIVATE_LINK.
- type string
- Selected networking type. Either PUBLIC,VPCorPRIVATE_LINK. Defaults toPUBLIC.
- connection_id str
- Id of the Private Link connection when type is PRIVATE_LINK.
- type str
- Selected networking type. Either PUBLIC,VPCorPRIVATE_LINK. Defaults toPUBLIC.
- connectionId String
- Id of the Private Link connection when type is PRIVATE_LINK.
- type String
- Selected networking type. Either PUBLIC,VPCorPRIVATE_LINK. Defaults toPUBLIC.
GetStreamConnectionSecurity   
- BrokerPublic stringCertificate 
- 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 PLAINTEXTorSSL.
- BrokerPublic stringCertificate 
- 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 PLAINTEXTorSSL.
- brokerPublic StringCertificate 
- 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 PLAINTEXTorSSL.
- brokerPublic stringCertificate 
- 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 PLAINTEXTorSSL.
- broker_public_ strcertificate 
- 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 PLAINTEXTorSSL.
- brokerPublic StringCertificate 
- 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 PLAINTEXTorSSL.
Package Details
- Repository
- MongoDB Atlas pulumi/pulumi-mongodbatlas
- License
- Apache-2.0
- Notes
- This Pulumi package is based on the mongodbatlasTerraform Provider.