Upstash v0.3.14 published on Friday, Aug 9, 2024 by Upstash
upstash.getKafkaTopic
Explore with Pulumi AI
Example Usage
using Pulumi;
using Upstash = Pulumi.Upstash;
class MyStack : Stack
{
    public MyStack()
    {
        var kafkaTopicData = Output.Create(Upstash.GetKafkaTopic.InvokeAsync(new Upstash.GetKafkaTopicArgs
        {
            TopicId = resource.Upstash_kafka_topic.ExampleKafkaTopic.Topic_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.LookupKafkaTopic(ctx, &GetKafkaTopicArgs{
			TopicId: resource.Upstash_kafka_topic.ExampleKafkaTopic.Topic_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 kafkaTopicData = Output.of(UpstashFunctions.getKafkaTopic(GetKafkaTopicArgs.builder()
            .topicId(resource.upstash_kafka_topic().exampleKafkaTopic().topic_id())
            .build()));
    }
}
import * as pulumi from "@pulumi/pulumi";
import * as upstash from "@pulumi/upstash";
const kafkaTopicData = upstash.getKafkaTopic({
    topicId: resource.upstash_kafka_topic.exampleKafkaTopic.topic_id,
});
import pulumi
import pulumi_upstash as upstash
kafka_topic_data = upstash.get_kafka_topic(topic_id=resource["upstash_kafka_topic"]["exampleKafkaTopic"]["topic_id"])
variables:
  kafkaTopicData:
    Fn::Invoke:
      Function: upstash:getKafkaTopic
      Arguments:
        topicId: ${resource.upstash_kafka_topic.exampleKafkaTopic.topic_id}
Using getKafkaTopic
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 getKafkaTopic(args: GetKafkaTopicArgs, opts?: InvokeOptions): Promise<GetKafkaTopicResult>
function getKafkaTopicOutput(args: GetKafkaTopicOutputArgs, opts?: InvokeOptions): Output<GetKafkaTopicResult>def get_kafka_topic(topic_id: Optional[str] = None,
                    opts: Optional[InvokeOptions] = None) -> GetKafkaTopicResult
def get_kafka_topic_output(topic_id: Optional[pulumi.Input[str]] = None,
                    opts: Optional[InvokeOptions] = None) -> Output[GetKafkaTopicResult]func LookupKafkaTopic(ctx *Context, args *LookupKafkaTopicArgs, opts ...InvokeOption) (*LookupKafkaTopicResult, error)
func LookupKafkaTopicOutput(ctx *Context, args *LookupKafkaTopicOutputArgs, opts ...InvokeOption) LookupKafkaTopicResultOutput> Note: This function is named LookupKafkaTopic in the Go SDK.
public static class GetKafkaTopic 
{
    public static Task<GetKafkaTopicResult> InvokeAsync(GetKafkaTopicArgs args, InvokeOptions? opts = null)
    public static Output<GetKafkaTopicResult> Invoke(GetKafkaTopicInvokeArgs args, InvokeOptions? opts = null)
}public static CompletableFuture<GetKafkaTopicResult> getKafkaTopic(GetKafkaTopicArgs args, InvokeOptions options)
public static Output<GetKafkaTopicResult> getKafkaTopic(GetKafkaTopicArgs args, InvokeOptions options)
fn::invoke:
  function: upstash:index/getKafkaTopic:getKafkaTopic
  arguments:
    # arguments dictionaryThe following arguments are supported:
- Topic
Id string 
- Topic
Id string 
- topic
Id String 
- topic
Id string 
- topic_
id str 
- topic
Id String 
getKafkaTopic Result
The following output properties are available:
- Cleanup
Policy string - Cluster
Id string - Creation
Time int - Id string
 - The provider-assigned unique ID for this managed resource.
 - Max
Message intSize  - Multizone bool
 - Partitions int
 - Password string
 - Region string
 - Rest
Endpoint string - Retention
Size int - Retention
Time int - State string
 - Tcp
Endpoint string - Topic
Id string - Topic
Name string - Username string
 
- Cleanup
Policy string - Cluster
Id string - Creation
Time int - Id string
 - The provider-assigned unique ID for this managed resource.
 - Max
Message intSize  - Multizone bool
 - Partitions int
 - Password string
 - Region string
 - Rest
Endpoint string - Retention
Size int - Retention
Time int - State string
 - Tcp
Endpoint string - Topic
Id string - Topic
Name string - Username string
 
- cleanup
Policy String - cluster
Id String - creation
Time Integer - id String
 - The provider-assigned unique ID for this managed resource.
 - max
Message IntegerSize  - multizone Boolean
 - partitions Integer
 - password String
 - region String
 - rest
Endpoint String - retention
Size Integer - retention
Time Integer - state String
 - tcp
Endpoint String - topic
Id String - topic
Name String - username String
 
- cleanup
Policy string - cluster
Id string - creation
Time number - id string
 - The provider-assigned unique ID for this managed resource.
 - max
Message numberSize  - multizone boolean
 - partitions number
 - password string
 - region string
 - rest
Endpoint string - retention
Size number - retention
Time number - state string
 - tcp
Endpoint string - topic
Id string - topic
Name string - username string
 
- cleanup_
policy str - cluster_
id str - creation_
time int - id str
 - The provider-assigned unique ID for this managed resource.
 - max_
message_ intsize  - multizone bool
 - partitions int
 - password str
 - region str
 - rest_
endpoint str - retention_
size int - retention_
time int - state str
 - tcp_
endpoint str - topic_
id str - topic_
name str - username str
 
- cleanup
Policy String - cluster
Id String - creation
Time Number - id String
 - The provider-assigned unique ID for this managed resource.
 - max
Message NumberSize  - multizone Boolean
 - partitions Number
 - password String
 - region String
 - rest
Endpoint String - retention
Size Number - retention
Time Number - state String
 - tcp
Endpoint String - topic
Id String - topic
Name String - username String
 
Package Details
- Repository
 - upstash upstash/pulumi-upstash
 - License
 - Apache-2.0
 - Notes
 - This Pulumi package is based on the 
upstashTerraform Provider.