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 pulumi
import pulumi_upstash as upstash
kafka_topic_data = upstash.get_kafka_topic(topic_id=resource["upstash_kafka_topic"]["exampleKafkaTopic"]["topic_id"])
import * as pulumi from "@pulumi/pulumi";
import * as upstash from "@pulumi/upstash";
const kafkaTopicData = upstash.getKafkaTopic({
topicId: 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)
// Output-based functions aren't available in Java yet
fn::invoke:
function: upstash:index/getKafkaTopic:getKafkaTopic
arguments:
# arguments dictionary
The 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
upstash
Terraform Provider.