1. Packages
  2. Upstash
  3. API Docs
  4. getKafkaConnector
Upstash v0.2.0 published on Wednesday, May 24, 2023 by Upstash

upstash.getKafkaConnector

Explore with Pulumi AI

upstash logo
Upstash v0.2.0 published on Wednesday, May 24, 2023 by Upstash

    Example Usage

    using Pulumi;
    using Upstash = Pulumi.Upstash;
    
    class MyStack : Stack
    {
        public MyStack()
        {
            var kafkaConnectorData = Output.Create(Upstash.GetKafkaConnector.InvokeAsync(new Upstash.GetKafkaConnectorArgs
            {
                TopicId = resource.Upstash_kafka_connector.ExampleKafkaConnector.Connector_id,
            }));
        }
    
    }
    
    package main
    
    import (
    	"github.com/pulumi/pulumi-upstash/sdk/go/upstash"
    	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
    	"github.com/upstash/pulumi-upstash/sdk/go/upstash"
    )
    
    func main() {
    	pulumi.Run(func(ctx *pulumi.Context) error {
    		_, err := upstash.LookupKafkaConnector(ctx, &GetKafkaConnectorArgs{
    			TopicId: resource.Upstash_kafka_connector.ExampleKafkaConnector.Connector_id,
    		}, nil)
    		if err != nil {
    			return err
    		}
    		return nil
    	})
    }
    
    package generated_program;
    
    import java.util.*;
    import java.io.*;
    import java.nio.*;
    import com.pulumi.*;
    
    public class App {
        public static void main(String[] args) {
            Pulumi.run(App::stack);
        }
    
        public static void stack(Context ctx) {
            final var kafkaConnectorData = Output.of(UpstashFunctions.getKafkaConnector(GetKafkaConnectorArgs.builder()
                .topicId(resource.upstash_kafka_connector().exampleKafkaConnector().connector_id())
                .build()));
    
        }
    }
    
    import pulumi
    import pulumi_upstash as upstash
    
    kafka_connector_data = upstash.get_kafka_connector(topic_id=resource["upstash_kafka_connector"]["exampleKafkaConnector"]["connector_id"])
    
    import * as pulumi from "@pulumi/pulumi";
    import * as upstash from "@pulumi/upstash";
    
    const kafkaConnectorData = upstash.getKafkaConnector({
        topicId: resource.upstash_kafka_connector.exampleKafkaConnector.connector_id,
    });
    
    variables:
      kafkaConnectorData:
        Fn::Invoke:
          Function: upstash:getKafkaConnector
          Arguments:
            topicId: ${resource.upstash_kafka_connector.exampleKafkaConnector.connector_id}
    

    Using getKafkaConnector

    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 getKafkaConnector(args: GetKafkaConnectorArgs, opts?: InvokeOptions): Promise<GetKafkaConnectorResult>
    function getKafkaConnectorOutput(args: GetKafkaConnectorOutputArgs, opts?: InvokeOptions): Output<GetKafkaConnectorResult>
    def get_kafka_connector(connector_id: Optional[str] = None,
                            opts: Optional[InvokeOptions] = None) -> GetKafkaConnectorResult
    def get_kafka_connector_output(connector_id: Optional[pulumi.Input[str]] = None,
                            opts: Optional[InvokeOptions] = None) -> Output[GetKafkaConnectorResult]
    func LookupKafkaConnector(ctx *Context, args *LookupKafkaConnectorArgs, opts ...InvokeOption) (*LookupKafkaConnectorResult, error)
    func LookupKafkaConnectorOutput(ctx *Context, args *LookupKafkaConnectorOutputArgs, opts ...InvokeOption) LookupKafkaConnectorResultOutput

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

    public static class GetKafkaConnector 
    {
        public static Task<GetKafkaConnectorResult> InvokeAsync(GetKafkaConnectorArgs args, InvokeOptions? opts = null)
        public static Output<GetKafkaConnectorResult> Invoke(GetKafkaConnectorInvokeArgs args, InvokeOptions? opts = null)
    }
    public static CompletableFuture<GetKafkaConnectorResult> getKafkaConnector(GetKafkaConnectorArgs args, InvokeOptions options)
    // Output-based functions aren't available in Java yet
    
    fn::invoke:
      function: upstash:index/getKafkaConnector:getKafkaConnector
      arguments:
        # arguments dictionary

    The following arguments are supported:

    getKafkaConnector Result

    The following output properties are available:

    ClusterId string
    ConnectorClass string
    ConnectorId string
    ConnectorState string
    CreationTime int
    EncodedUsername string
    Id string
    The provider-assigned unique ID for this managed resource.
    Name string
    Properties Dictionary<string, object>
    PropertiesEncrypted string
    State string
    StateErrorMessage string
    Tasks List<ImmutableDictionary<string, object>>
    Topics List<string>
    Ttl int
    UserPassword string
    ClusterId string
    ConnectorClass string
    ConnectorId string
    ConnectorState string
    CreationTime int
    EncodedUsername string
    Id string
    The provider-assigned unique ID for this managed resource.
    Name string
    Properties map[string]interface{}
    PropertiesEncrypted string
    State string
    StateErrorMessage string
    Tasks []map[string]interface{}
    Topics []string
    Ttl int
    UserPassword string
    clusterId String
    connectorClass String
    connectorId String
    connectorState String
    creationTime Integer
    encodedUsername String
    id String
    The provider-assigned unique ID for this managed resource.
    name String
    properties Map<String,Object>
    propertiesEncrypted String
    state String
    stateErrorMessage String
    tasks List<Map<String,Object>>
    topics List<String>
    ttl Integer
    userPassword String
    clusterId string
    connectorClass string
    connectorId string
    connectorState string
    creationTime number
    encodedUsername string
    id string
    The provider-assigned unique ID for this managed resource.
    name string
    properties {[key: string]: any}
    propertiesEncrypted string
    state string
    stateErrorMessage string
    tasks {[key: string]: any}[]
    topics string[]
    ttl number
    userPassword string
    cluster_id str
    connector_class str
    connector_id str
    connector_state str
    creation_time int
    encoded_username str
    id str
    The provider-assigned unique ID for this managed resource.
    name str
    properties Mapping[str, Any]
    properties_encrypted str
    state str
    state_error_message str
    tasks Sequence[Mapping[str, Any]]
    topics Sequence[str]
    ttl int
    user_password str
    clusterId String
    connectorClass String
    connectorId String
    connectorState String
    creationTime Number
    encodedUsername String
    id String
    The provider-assigned unique ID for this managed resource.
    name String
    properties Map<Any>
    propertiesEncrypted String
    state String
    stateErrorMessage String
    tasks List<Map<Any>>
    topics List<String>
    ttl Number
    userPassword String

    Package Details

    Repository
    upstash upstash/pulumi-upstash
    License
    Apache-2.0
    Notes
    This Pulumi package is based on the upstash Terraform Provider.
    upstash logo
    Upstash v0.2.0 published on Wednesday, May 24, 2023 by Upstash