Docs Home Pulumi IaC Pulumi ESC Pulumi Insights Pulumi IDP Pulumi Cloud Packages Tutorials
  1. Packages
  2. Confluent Provider
  3. API Docs
  4. FlinkConnection
Confluent v2.31.0 published on Friday, Jun 13, 2025 by Pulumi
pulumi/pulumi-confluentcloud

confluentcloud.FlinkConnection

Explore with Pulumi AI

confluentcloud logo
Confluent v2.31.0 published on Friday, Jun 13, 2025 by Pulumi
pulumi/pulumi-confluentcloud

    Import

    You can import a Flink connection by using the Flink Connection name, for example:

    Option #1: Manage multiple Flink Compute Pools in the same Pulumi Stack

    $ export IMPORT_CONFLUENT_ORGANIZATION_ID="<organization_id>"

    $ export IMPORT_CONFLUENT_ENVIRONMENT_ID="<environment_id>"

    $ export IMPORT_FLINK_COMPUTE_POOL_ID="<flink_compute_pool_id>"

    $ export IMPORT_FLINK_API_KEY="<flink_api_key>"

    $ export IMPORT_FLINK_API_SECRET="<flink_api_secret>"

    $ export IMPORT_FLINK_REST_ENDPOINT="<flink_rest_endpoint>"

    $ export IMPORT_FLINK_PRINCIPAL_ID="<flink_principal>"

    $ export API_KEY="<API_KEY>"

    $ pulumi import confluentcloud:index/flinkConnection:FlinkConnection example org-xyz123/env-abc123/connection1

    Option #2: Manage a single Flink Compute Pool in the same Pulumi Stack

    $ export API_KEY="<API_KEY>"

    $ pulumi import confluentcloud:index/flinkConnection:FlinkConnection example org-xyz123/env-abc123/connection1

    !> Warning: Do not forget to delete terminal command history afterwards for security purposes.

    Create FlinkConnection Resource

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

    Constructor syntax

    new FlinkConnection(name: string, args: FlinkConnectionArgs, opts?: CustomResourceOptions);
    @overload
def FlinkConnection(resource_name: str,
                    args: FlinkConnectionArgs,
                    opts: Optional[ResourceOptions] = None)

@overload
def FlinkConnection(resource_name: str,
                    opts: Optional[ResourceOptions] = None,
                    display_name: Optional[str] = None,
                    type: Optional[str] = None,
                    endpoint: Optional[str] = None,
                    environment: Optional[FlinkConnectionEnvironmentArgs] = None,
                    compute_pool: Optional[FlinkConnectionComputePoolArgs] = None,
                    credentials: Optional[FlinkConnectionCredentialsArgs] = None,
                    aws_session_token: Optional[str] = None,
                    aws_secret_key: Optional[str] = None,
                    api_key: Optional[str] = None,
                    organization: Optional[FlinkConnectionOrganizationArgs] = None,
                    password: Optional[str] = None,
                    principal: Optional[FlinkConnectionPrincipalArgs] = None,
                    rest_endpoint: Optional[str] = None,
                    service_key: Optional[str] = None,
                    aws_access_key: Optional[str] = None,
                    username: Optional[str] = None)
    func NewFlinkConnection(ctx *Context, name string, args FlinkConnectionArgs, opts ...ResourceOption) (*FlinkConnection, error)
    public FlinkConnection(string name, FlinkConnectionArgs args, CustomResourceOptions? opts = null)
    public FlinkConnection(String name, FlinkConnectionArgs args)
public FlinkConnection(String name, FlinkConnectionArgs args, CustomResourceOptions options)

    type: confluentcloud:FlinkConnection
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 FlinkConnectionArgs
    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 FlinkConnectionArgs
    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 FlinkConnectionArgs
    The arguments to resource properties.
    opts ResourceOption
    Bag of options to control resource's behavior.
    name string
    The unique name of the resource.
    args FlinkConnectionArgs
    The arguments to resource properties.
    opts CustomResourceOptions
    Bag of options to control resource's behavior.
    name String
    The unique name of the resource.
    args FlinkConnectionArgs
    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 flinkConnectionResource = new ConfluentCloud.FlinkConnection("flinkConnectionResource", new()
{
    DisplayName = "string",
    Type = "string",
    Endpoint = "string",
    Environment = new ConfluentCloud.Inputs.FlinkConnectionEnvironmentArgs
    {
        Id = "string",
    },
    ComputePool = new ConfluentCloud.Inputs.FlinkConnectionComputePoolArgs
    {
        Id = "string",
    },
    Credentials = new ConfluentCloud.Inputs.FlinkConnectionCredentialsArgs
    {
        Key = "string",
        Secret = "string",
    },
    AwsSessionToken = "string",
    AwsSecretKey = "string",
    ApiKey = "string",
    Organization = new ConfluentCloud.Inputs.FlinkConnectionOrganizationArgs
    {
        Id = "string",
    },
    Password = "string",
    Principal = new ConfluentCloud.Inputs.FlinkConnectionPrincipalArgs
    {
        Id = "string",
    },
    RestEndpoint = "string",
    ServiceKey = "string",
    AwsAccessKey = "string",
    Username = "string",
});

    example, err := confluentcloud.NewFlinkConnection(ctx, "flinkConnectionResource", &confluentcloud.FlinkConnectionArgs{
	DisplayName: pulumi.String("string"),
	Type:        pulumi.String("string"),
	Endpoint:    pulumi.String("string"),
	Environment: &confluentcloud.FlinkConnectionEnvironmentArgs{
		Id: pulumi.String("string"),
	},
	ComputePool: &confluentcloud.FlinkConnectionComputePoolArgs{
		Id: pulumi.String("string"),
	},
	Credentials: &confluentcloud.FlinkConnectionCredentialsArgs{
		Key:    pulumi.String("string"),
		Secret: pulumi.String("string"),
	},
	AwsSessionToken: pulumi.String("string"),
	AwsSecretKey:    pulumi.String("string"),
	ApiKey:          pulumi.String("string"),
	Organization: &confluentcloud.FlinkConnectionOrganizationArgs{
		Id: pulumi.String("string"),
	},
	Password: pulumi.String("string"),
	Principal: &confluentcloud.FlinkConnectionPrincipalArgs{
		Id: pulumi.String("string"),
	},
	RestEndpoint: pulumi.String("string"),
	ServiceKey:   pulumi.String("string"),
	AwsAccessKey: pulumi.String("string"),
	Username:     pulumi.String("string"),
})

    var flinkConnectionResource = new FlinkConnection("flinkConnectionResource", FlinkConnectionArgs.builder()
    .displayName("string")
    .type("string")
    .endpoint("string")
    .environment(FlinkConnectionEnvironmentArgs.builder()
        .id("string")
        .build())
    .computePool(FlinkConnectionComputePoolArgs.builder()
        .id("string")
        .build())
    .credentials(FlinkConnectionCredentialsArgs.builder()
        .key("string")
        .secret("string")
        .build())
    .awsSessionToken("string")
    .awsSecretKey("string")
    .apiKey("string")
    .organization(FlinkConnectionOrganizationArgs.builder()
        .id("string")
        .build())
    .password("string")
    .principal(FlinkConnectionPrincipalArgs.builder()
        .id("string")
        .build())
    .restEndpoint("string")
    .serviceKey("string")
    .awsAccessKey("string")
    .username("string")
    .build());

    flink_connection_resource = confluentcloud.FlinkConnection("flinkConnectionResource",
    display_name="string",
    type="string",
    endpoint="string",
    environment={
        "id": "string",
    },
    compute_pool={
        "id": "string",
    },
    credentials={
        "key": "string",
        "secret": "string",
    },
    aws_session_token="string",
    aws_secret_key="string",
    api_key="string",
    organization={
        "id": "string",
    },
    password="string",
    principal={
        "id": "string",
    },
    rest_endpoint="string",
    service_key="string",
    aws_access_key="string",
    username="string")

    const flinkConnectionResource = new confluentcloud.FlinkConnection("flinkConnectionResource", {
    displayName: "string",
    type: "string",
    endpoint: "string",
    environment: {
        id: "string",
    },
    computePool: {
        id: "string",
    },
    credentials: {
        key: "string",
        secret: "string",
    },
    awsSessionToken: "string",
    awsSecretKey: "string",
    apiKey: "string",
    organization: {
        id: "string",
    },
    password: "string",
    principal: {
        id: "string",
    },
    restEndpoint: "string",
    serviceKey: "string",
    awsAccessKey: "string",
    username: "string",
});

    type: confluentcloud:FlinkConnection
properties:
    apiKey: string
    awsAccessKey: string
    awsSecretKey: string
    awsSessionToken: string
    computePool:
        id: string
    credentials:
        key: string
        secret: string
    displayName: string
    endpoint: string
    environment:
        id: string
    organization:
        id: string
    password: string
    principal:
        id: string
    restEndpoint: string
    serviceKey: string
    type: string
    username: string

    FlinkConnection Resource Properties

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

    Inputs

    In Python, inputs that are objects can be passed either as argument classes or as dictionary literals.

    The FlinkConnection resource accepts the following input properties:

    DisplayName string
    The unique name of the Flink Connection per organization, environment scope.
    Endpoint string
    The endpoint of the flink connection.
    Type string
    The type of the flink connection.
    ApiKey string
    API key for the type.
    AwsAccessKey string
    Access key for the type.
    AwsSecretKey string
    Secret key for the type.
    AwsSessionToken string
    Session token for the type.
    ComputePool Pulumi.ConfluentCloud.Inputs.FlinkConnectionComputePool
    Credentials Pulumi.ConfluentCloud.Inputs.FlinkConnectionCredentials
    The Cluster API Credentials.
    Environment Pulumi.ConfluentCloud.Inputs.FlinkConnectionEnvironment
    Organization Pulumi.ConfluentCloud.Inputs.FlinkConnectionOrganization
    Password string
    Password for the type.
    Principal Pulumi.ConfluentCloud.Inputs.FlinkConnectionPrincipal
    RestEndpoint string
    The REST endpoint of the Flink Connection cluster, for example, https://flink.us-east-1.aws.confluent.cloud/sql/v1/organizations/1111aaaa-11aa-11aa-11aa-111111aaaaaa/environments/env-abc123).
    ServiceKey string
    Service Key for the type.
    Username string
    Username for the type.
    DisplayName string
    The unique name of the Flink Connection per organization, environment scope.
    Endpoint string
    The endpoint of the flink connection.
    Type string
    The type of the flink connection.
    ApiKey string
    API key for the type.
    AwsAccessKey string
    Access key for the type.
    AwsSecretKey string
    Secret key for the type.
    AwsSessionToken string
    Session token for the type.
    ComputePool FlinkConnectionComputePoolArgs
    Credentials FlinkConnectionCredentialsArgs
    The Cluster API Credentials.
    Environment FlinkConnectionEnvironmentArgs
    Organization FlinkConnectionOrganizationArgs
    Password string
    Password for the type.
    Principal FlinkConnectionPrincipalArgs
    RestEndpoint string
    The REST endpoint of the Flink Connection cluster, for example, https://flink.us-east-1.aws.confluent.cloud/sql/v1/organizations/1111aaaa-11aa-11aa-11aa-111111aaaaaa/environments/env-abc123).
    ServiceKey string
    Service Key for the type.
    Username string
    Username for the type.
    displayName String
    The unique name of the Flink Connection per organization, environment scope.
    endpoint String
    The endpoint of the flink connection.
    type String
    The type of the flink connection.
    apiKey String
    API key for the type.
    awsAccessKey String
    Access key for the type.
    awsSecretKey String
    Secret key for the type.
    awsSessionToken String
    Session token for the type.
    computePool FlinkConnectionComputePool
    credentials FlinkConnectionCredentials
    The Cluster API Credentials.
    environment FlinkConnectionEnvironment
    organization FlinkConnectionOrganization
    password String
    Password for the type.
    principal FlinkConnectionPrincipal
    restEndpoint String
    The REST endpoint of the Flink Connection cluster, for example, https://flink.us-east-1.aws.confluent.cloud/sql/v1/organizations/1111aaaa-11aa-11aa-11aa-111111aaaaaa/environments/env-abc123).
    serviceKey String
    Service Key for the type.
    username String
    Username for the type.
    displayName string
    The unique name of the Flink Connection per organization, environment scope.
    endpoint string
    The endpoint of the flink connection.
    type string
    The type of the flink connection.
    apiKey string
    API key for the type.
    awsAccessKey string
    Access key for the type.
    awsSecretKey string
    Secret key for the type.
    awsSessionToken string
    Session token for the type.
    computePool FlinkConnectionComputePool
    credentials FlinkConnectionCredentials
    The Cluster API Credentials.
    environment FlinkConnectionEnvironment
    organization FlinkConnectionOrganization
    password string
    Password for the type.
    principal FlinkConnectionPrincipal
    restEndpoint string
    The REST endpoint of the Flink Connection cluster, for example, https://flink.us-east-1.aws.confluent.cloud/sql/v1/organizations/1111aaaa-11aa-11aa-11aa-111111aaaaaa/environments/env-abc123).
    serviceKey string
    Service Key for the type.
    username string
    Username for the type.
    display_name str
    The unique name of the Flink Connection per organization, environment scope.
    endpoint str
    The endpoint of the flink connection.
    type str
    The type of the flink connection.
    api_key str
    API key for the type.
    aws_access_key str
    Access key for the type.
    aws_secret_key str
    Secret key for the type.
    aws_session_token str
    Session token for the type.
    compute_pool FlinkConnectionComputePoolArgs
    credentials FlinkConnectionCredentialsArgs
    The Cluster API Credentials.
    environment FlinkConnectionEnvironmentArgs
    organization FlinkConnectionOrganizationArgs
    password str
    Password for the type.
    principal FlinkConnectionPrincipalArgs
    rest_endpoint str
    The REST endpoint of the Flink Connection cluster, for example, https://flink.us-east-1.aws.confluent.cloud/sql/v1/organizations/1111aaaa-11aa-11aa-11aa-111111aaaaaa/environments/env-abc123).
    service_key str
    Service Key for the type.
    username str
    Username for the type.
    displayName String
    The unique name of the Flink Connection per organization, environment scope.
    endpoint String
    The endpoint of the flink connection.
    type String
    The type of the flink connection.
    apiKey String
    API key for the type.
    awsAccessKey String
    Access key for the type.
    awsSecretKey String
    Secret key for the type.
    awsSessionToken String
    Session token for the type.
    computePool Property Map
    credentials Property Map
    The Cluster API Credentials.
    environment Property Map
    organization Property Map
    password String
    Password for the type.
    principal Property Map
    restEndpoint String
    The REST endpoint of the Flink Connection cluster, for example, https://flink.us-east-1.aws.confluent.cloud/sql/v1/organizations/1111aaaa-11aa-11aa-11aa-111111aaaaaa/environments/env-abc123).
    serviceKey String
    Service Key for the type.
    username String
    Username for the type.

    Outputs

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

    ApiVersion string
    The schema version of this representation of a resource.
    Id string
    The provider-assigned unique ID for this managed resource.
    Kind string
    The object this REST resource represents.
    ApiVersion string
    The schema version of this representation of a resource.
    Id string
    The provider-assigned unique ID for this managed resource.
    Kind string
    The object this REST resource represents.
    apiVersion String
    The schema version of this representation of a resource.
    id String
    The provider-assigned unique ID for this managed resource.
    kind String
    The object this REST resource represents.
    apiVersion string
    The schema version of this representation of a resource.
    id string
    The provider-assigned unique ID for this managed resource.
    kind string
    The object this REST resource represents.
    api_version str
    The schema version of this representation of a resource.
    id str
    The provider-assigned unique ID for this managed resource.
    kind str
    The object this REST resource represents.
    apiVersion String
    The schema version of this representation of a resource.
    id String
    The provider-assigned unique ID for this managed resource.
    kind String
    The object this REST resource represents.

    Look up Existing FlinkConnection Resource

    Get an existing FlinkConnection 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?: FlinkConnectionState, opts?: CustomResourceOptions): FlinkConnection
    @staticmethod
def get(resource_name: str,
        id: str,
        opts: Optional[ResourceOptions] = None,
        api_key: Optional[str] = None,
        api_version: Optional[str] = None,
        aws_access_key: Optional[str] = None,
        aws_secret_key: Optional[str] = None,
        aws_session_token: Optional[str] = None,
        compute_pool: Optional[FlinkConnectionComputePoolArgs] = None,
        credentials: Optional[FlinkConnectionCredentialsArgs] = None,
        display_name: Optional[str] = None,
        endpoint: Optional[str] = None,
        environment: Optional[FlinkConnectionEnvironmentArgs] = None,
        kind: Optional[str] = None,
        organization: Optional[FlinkConnectionOrganizationArgs] = None,
        password: Optional[str] = None,
        principal: Optional[FlinkConnectionPrincipalArgs] = None,
        rest_endpoint: Optional[str] = None,
        service_key: Optional[str] = None,
        type: Optional[str] = None,
        username: Optional[str] = None) -> FlinkConnection
    func GetFlinkConnection(ctx *Context, name string, id IDInput, state *FlinkConnectionState, opts ...ResourceOption) (*FlinkConnection, error)
    public static FlinkConnection Get(string name, Input<string> id, FlinkConnectionState? state, CustomResourceOptions? opts = null)
    public static FlinkConnection get(String name, Output<String> id, FlinkConnectionState state, CustomResourceOptions options)
    resources:  _:    type: confluentcloud:FlinkConnection    get:      id: ${id}
    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:
    ApiKey string
    API key for the type.
    ApiVersion string
    The schema version of this representation of a resource.
    AwsAccessKey string
    Access key for the type.
    AwsSecretKey string
    Secret key for the type.
    AwsSessionToken string
    Session token for the type.
    ComputePool Pulumi.ConfluentCloud.Inputs.FlinkConnectionComputePool
    Credentials Pulumi.ConfluentCloud.Inputs.FlinkConnectionCredentials
    The Cluster API Credentials.
    DisplayName string
    The unique name of the Flink Connection per organization, environment scope.
    Endpoint string
    The endpoint of the flink connection.
    Environment Pulumi.ConfluentCloud.Inputs.FlinkConnectionEnvironment
    Kind string
    The object this REST resource represents.
    Organization Pulumi.ConfluentCloud.Inputs.FlinkConnectionOrganization
    Password string
    Password for the type.
    Principal Pulumi.ConfluentCloud.Inputs.FlinkConnectionPrincipal
    RestEndpoint string
    The REST endpoint of the Flink Connection cluster, for example, https://flink.us-east-1.aws.confluent.cloud/sql/v1/organizations/1111aaaa-11aa-11aa-11aa-111111aaaaaa/environments/env-abc123).
    ServiceKey string
    Service Key for the type.
    Type string
    The type of the flink connection.
    Username string
    Username for the type.
    ApiKey string
    API key for the type.
    ApiVersion string
    The schema version of this representation of a resource.
    AwsAccessKey string
    Access key for the type.
    AwsSecretKey string
    Secret key for the type.
    AwsSessionToken string
    Session token for the type.
    ComputePool FlinkConnectionComputePoolArgs
    Credentials FlinkConnectionCredentialsArgs
    The Cluster API Credentials.
    DisplayName string
    The unique name of the Flink Connection per organization, environment scope.
    Endpoint string
    The endpoint of the flink connection.
    Environment FlinkConnectionEnvironmentArgs
    Kind string
    The object this REST resource represents.
    Organization FlinkConnectionOrganizationArgs
    Password string
    Password for the type.
    Principal FlinkConnectionPrincipalArgs
    RestEndpoint string
    The REST endpoint of the Flink Connection cluster, for example, https://flink.us-east-1.aws.confluent.cloud/sql/v1/organizations/1111aaaa-11aa-11aa-11aa-111111aaaaaa/environments/env-abc123).
    ServiceKey string
    Service Key for the type.
    Type string
    The type of the flink connection.
    Username string
    Username for the type.
    apiKey String
    API key for the type.
    apiVersion String
    The schema version of this representation of a resource.
    awsAccessKey String
    Access key for the type.
    awsSecretKey String
    Secret key for the type.
    awsSessionToken String
    Session token for the type.
    computePool FlinkConnectionComputePool
    credentials FlinkConnectionCredentials
    The Cluster API Credentials.
    displayName String
    The unique name of the Flink Connection per organization, environment scope.
    endpoint String
    The endpoint of the flink connection.
    environment FlinkConnectionEnvironment
    kind String
    The object this REST resource represents.
    organization FlinkConnectionOrganization
    password String
    Password for the type.
    principal FlinkConnectionPrincipal
    restEndpoint String
    The REST endpoint of the Flink Connection cluster, for example, https://flink.us-east-1.aws.confluent.cloud/sql/v1/organizations/1111aaaa-11aa-11aa-11aa-111111aaaaaa/environments/env-abc123).
    serviceKey String
    Service Key for the type.
    type String
    The type of the flink connection.
    username String
    Username for the type.
    apiKey string
    API key for the type.
    apiVersion string
    The schema version of this representation of a resource.
    awsAccessKey string
    Access key for the type.
    awsSecretKey string
    Secret key for the type.
    awsSessionToken string
    Session token for the type.
    computePool FlinkConnectionComputePool
    credentials FlinkConnectionCredentials
    The Cluster API Credentials.
    displayName string
    The unique name of the Flink Connection per organization, environment scope.
    endpoint string
    The endpoint of the flink connection.
    environment FlinkConnectionEnvironment
    kind string
    The object this REST resource represents.
    organization FlinkConnectionOrganization
    password string
    Password for the type.
    principal FlinkConnectionPrincipal
    restEndpoint string
    The REST endpoint of the Flink Connection cluster, for example, https://flink.us-east-1.aws.confluent.cloud/sql/v1/organizations/1111aaaa-11aa-11aa-11aa-111111aaaaaa/environments/env-abc123).
    serviceKey string
    Service Key for the type.
    type string
    The type of the flink connection.
    username string
    Username for the type.
    api_key str
    API key for the type.
    api_version str
    The schema version of this representation of a resource.
    aws_access_key str
    Access key for the type.
    aws_secret_key str
    Secret key for the type.
    aws_session_token str
    Session token for the type.
    compute_pool FlinkConnectionComputePoolArgs
    credentials FlinkConnectionCredentialsArgs
    The Cluster API Credentials.
    display_name str
    The unique name of the Flink Connection per organization, environment scope.
    endpoint str
    The endpoint of the flink connection.
    environment FlinkConnectionEnvironmentArgs
    kind str
    The object this REST resource represents.
    organization FlinkConnectionOrganizationArgs
    password str
    Password for the type.
    principal FlinkConnectionPrincipalArgs
    rest_endpoint str
    The REST endpoint of the Flink Connection cluster, for example, https://flink.us-east-1.aws.confluent.cloud/sql/v1/organizations/1111aaaa-11aa-11aa-11aa-111111aaaaaa/environments/env-abc123).
    service_key str
    Service Key for the type.
    type str
    The type of the flink connection.
    username str
    Username for the type.
    apiKey String
    API key for the type.
    apiVersion String
    The schema version of this representation of a resource.
    awsAccessKey String
    Access key for the type.
    awsSecretKey String
    Secret key for the type.
    awsSessionToken String
    Session token for the type.
    computePool Property Map
    credentials Property Map
    The Cluster API Credentials.
    displayName String
    The unique name of the Flink Connection per organization, environment scope.
    endpoint String
    The endpoint of the flink connection.
    environment Property Map
    kind String
    The object this REST resource represents.
    organization Property Map
    password String
    Password for the type.
    principal Property Map
    restEndpoint String
    The REST endpoint of the Flink Connection cluster, for example, https://flink.us-east-1.aws.confluent.cloud/sql/v1/organizations/1111aaaa-11aa-11aa-11aa-111111aaaaaa/environments/env-abc123).
    serviceKey String
    Service Key for the type.
    type String
    The type of the flink connection.
    username String
    Username for the type.

    Supporting Types

    FlinkConnectionComputePool, FlinkConnectionComputePoolArgs

    Id string
    Id string
    id String
    id string
    id str
    id String

    FlinkConnectionCredentials, FlinkConnectionCredentialsArgs

    Key string
    The Cluster API Key for your Confluent Cloud cluster.
    Secret string
    The Cluster API Secret for your Confluent Cloud cluster.
    Key string
    The Cluster API Key for your Confluent Cloud cluster.
    Secret string
    The Cluster API Secret for your Confluent Cloud cluster.
    key String
    The Cluster API Key for your Confluent Cloud cluster.
    secret String
    The Cluster API Secret for your Confluent Cloud cluster.
    key string
    The Cluster API Key for your Confluent Cloud cluster.
    secret string
    The Cluster API Secret for your Confluent Cloud cluster.
    key str
    The Cluster API Key for your Confluent Cloud cluster.
    secret str
    The Cluster API Secret for your Confluent Cloud cluster.
    key String
    The Cluster API Key for your Confluent Cloud cluster.
    secret String
    The Cluster API Secret for your Confluent Cloud cluster.

    FlinkConnectionEnvironment, FlinkConnectionEnvironmentArgs

    Id string
    Id string
    id String
    id string
    id str
    id String

    FlinkConnectionOrganization, FlinkConnectionOrganizationArgs

    Id string
    Id string
    id String
    id string
    id str
    id String

    FlinkConnectionPrincipal, FlinkConnectionPrincipalArgs

    Id string
    Id string
    id String
    id string
    id str
    id String

    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
    Confluent v2.31.0 published on Friday, Jun 13, 2025 by Pulumi
    pulumi/pulumi-confluentcloud