1. Packages
  2. Tencentcloud Provider
  3. API Docs
  4. getCkafkaTopicSyncReplica
tencentcloud 1.81.187 published on Monday, Apr 28, 2025 by tencentcloudstack

tencentcloud.getCkafkaTopicSyncReplica

Explore with Pulumi AI

Use this data source to query detailed information of ckafka topic_sync_replica

Example Usage

import * as pulumi from "@pulumi/pulumi";
import * as tencentcloud from "@pulumi/tencentcloud";

const topicSyncReplica = tencentcloud.getCkafkaTopicSyncReplica({
    instanceId: "ckafka-xxxxxx",
    topicName: "xxxxxx",
});
Copy
import pulumi
import pulumi_tencentcloud as tencentcloud

topic_sync_replica = tencentcloud.get_ckafka_topic_sync_replica(instance_id="ckafka-xxxxxx",
    topic_name="xxxxxx")
Copy
package main

import (
	"github.com/pulumi/pulumi-terraform-provider/sdks/go/tencentcloud/tencentcloud"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := tencentcloud.GetCkafkaTopicSyncReplica(ctx, &tencentcloud.GetCkafkaTopicSyncReplicaArgs{
			InstanceId: "ckafka-xxxxxx",
			TopicName:  "xxxxxx",
		}, nil)
		if err != nil {
			return err
		}
		return nil
	})
}
Copy
using System.Collections.Generic;
using System.Linq;
using Pulumi;
using Tencentcloud = Pulumi.Tencentcloud;

return await Deployment.RunAsync(() => 
{
    var topicSyncReplica = Tencentcloud.GetCkafkaTopicSyncReplica.Invoke(new()
    {
        InstanceId = "ckafka-xxxxxx",
        TopicName = "xxxxxx",
    });

});
Copy
package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.tencentcloud.TencentcloudFunctions;
import com.pulumi.tencentcloud.inputs.GetCkafkaTopicSyncReplicaArgs;
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 topicSyncReplica = TencentcloudFunctions.getCkafkaTopicSyncReplica(GetCkafkaTopicSyncReplicaArgs.builder()
            .instanceId("ckafka-xxxxxx")
            .topicName("xxxxxx")
            .build());

    }
}
Copy
variables:
  topicSyncReplica:
    fn::invoke:
      function: tencentcloud:getCkafkaTopicSyncReplica
      arguments:
        instanceId: ckafka-xxxxxx
        topicName: xxxxxx
Copy

Using getCkafkaTopicSyncReplica

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 getCkafkaTopicSyncReplica(args: GetCkafkaTopicSyncReplicaArgs, opts?: InvokeOptions): Promise<GetCkafkaTopicSyncReplicaResult>
function getCkafkaTopicSyncReplicaOutput(args: GetCkafkaTopicSyncReplicaOutputArgs, opts?: InvokeOptions): Output<GetCkafkaTopicSyncReplicaResult>
Copy
def get_ckafka_topic_sync_replica(id: Optional[str] = None,
                                  instance_id: Optional[str] = None,
                                  out_of_sync_replica_only: Optional[bool] = None,
                                  result_output_file: Optional[str] = None,
                                  topic_name: Optional[str] = None,
                                  opts: Optional[InvokeOptions] = None) -> GetCkafkaTopicSyncReplicaResult
def get_ckafka_topic_sync_replica_output(id: Optional[pulumi.Input[str]] = None,
                                  instance_id: Optional[pulumi.Input[str]] = None,
                                  out_of_sync_replica_only: Optional[pulumi.Input[bool]] = None,
                                  result_output_file: Optional[pulumi.Input[str]] = None,
                                  topic_name: Optional[pulumi.Input[str]] = None,
                                  opts: Optional[InvokeOptions] = None) -> Output[GetCkafkaTopicSyncReplicaResult]
Copy
func GetCkafkaTopicSyncReplica(ctx *Context, args *GetCkafkaTopicSyncReplicaArgs, opts ...InvokeOption) (*GetCkafkaTopicSyncReplicaResult, error)
func GetCkafkaTopicSyncReplicaOutput(ctx *Context, args *GetCkafkaTopicSyncReplicaOutputArgs, opts ...InvokeOption) GetCkafkaTopicSyncReplicaResultOutput
Copy

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

public static class GetCkafkaTopicSyncReplica 
{
    public static Task<GetCkafkaTopicSyncReplicaResult> InvokeAsync(GetCkafkaTopicSyncReplicaArgs args, InvokeOptions? opts = null)
    public static Output<GetCkafkaTopicSyncReplicaResult> Invoke(GetCkafkaTopicSyncReplicaInvokeArgs args, InvokeOptions? opts = null)
}
Copy
public static CompletableFuture<GetCkafkaTopicSyncReplicaResult> getCkafkaTopicSyncReplica(GetCkafkaTopicSyncReplicaArgs args, InvokeOptions options)
public static Output<GetCkafkaTopicSyncReplicaResult> getCkafkaTopicSyncReplica(GetCkafkaTopicSyncReplicaArgs args, InvokeOptions options)
Copy
fn::invoke:
  function: tencentcloud:index/getCkafkaTopicSyncReplica:getCkafkaTopicSyncReplica
  arguments:
    # arguments dictionary
Copy

The following arguments are supported:

InstanceId This property is required. string
InstanceId.
TopicName This property is required. string
TopicName.
Id string
OutOfSyncReplicaOnly bool
Filter only unsynced replicas.
ResultOutputFile string
Used to save results.
InstanceId This property is required. string
InstanceId.
TopicName This property is required. string
TopicName.
Id string
OutOfSyncReplicaOnly bool
Filter only unsynced replicas.
ResultOutputFile string
Used to save results.
instanceId This property is required. String
InstanceId.
topicName This property is required. String
TopicName.
id String
outOfSyncReplicaOnly Boolean
Filter only unsynced replicas.
resultOutputFile String
Used to save results.
instanceId This property is required. string
InstanceId.
topicName This property is required. string
TopicName.
id string
outOfSyncReplicaOnly boolean
Filter only unsynced replicas.
resultOutputFile string
Used to save results.
instance_id This property is required. str
InstanceId.
topic_name This property is required. str
TopicName.
id str
out_of_sync_replica_only bool
Filter only unsynced replicas.
result_output_file str
Used to save results.
instanceId This property is required. String
InstanceId.
topicName This property is required. String
TopicName.
id String
outOfSyncReplicaOnly Boolean
Filter only unsynced replicas.
resultOutputFile String
Used to save results.

getCkafkaTopicSyncReplica Result

The following output properties are available:

id String
instanceId String
topicInSyncReplicaLists List<Property Map>
Topic details and copy collection.
topicName String
outOfSyncReplicaOnly Boolean
resultOutputFile String

Supporting Types

GetCkafkaTopicSyncReplicaTopicInSyncReplicaList

BeginOffset This property is required. double
BeginOffset.
EndOffset This property is required. double
EndOffset.
InSyncReplica This property is required. string
ISR.
Leader This property is required. double
Leader Id.
MessageCount This property is required. double
Message Count.
OutOfSyncReplica This property is required. string
Out Of Sync Replica.
Partition This property is required. string
partition name.
Replica This property is required. string
replica set.
BeginOffset This property is required. float64
BeginOffset.
EndOffset This property is required. float64
EndOffset.
InSyncReplica This property is required. string
ISR.
Leader This property is required. float64
Leader Id.
MessageCount This property is required. float64
Message Count.
OutOfSyncReplica This property is required. string
Out Of Sync Replica.
Partition This property is required. string
partition name.
Replica This property is required. string
replica set.
beginOffset This property is required. Double
BeginOffset.
endOffset This property is required. Double
EndOffset.
inSyncReplica This property is required. String
ISR.
leader This property is required. Double
Leader Id.
messageCount This property is required. Double
Message Count.
outOfSyncReplica This property is required. String
Out Of Sync Replica.
partition This property is required. String
partition name.
replica This property is required. String
replica set.
beginOffset This property is required. number
BeginOffset.
endOffset This property is required. number
EndOffset.
inSyncReplica This property is required. string
ISR.
leader This property is required. number
Leader Id.
messageCount This property is required. number
Message Count.
outOfSyncReplica This property is required. string
Out Of Sync Replica.
partition This property is required. string
partition name.
replica This property is required. string
replica set.
begin_offset This property is required. float
BeginOffset.
end_offset This property is required. float
EndOffset.
in_sync_replica This property is required. str
ISR.
leader This property is required. float
Leader Id.
message_count This property is required. float
Message Count.
out_of_sync_replica This property is required. str
Out Of Sync Replica.
partition This property is required. str
partition name.
replica This property is required. str
replica set.
beginOffset This property is required. Number
BeginOffset.
endOffset This property is required. Number
EndOffset.
inSyncReplica This property is required. String
ISR.
leader This property is required. Number
Leader Id.
messageCount This property is required. Number
Message Count.
outOfSyncReplica This property is required. String
Out Of Sync Replica.
partition This property is required. String
partition name.
replica This property is required. String
replica set.

Package Details

Repository
tencentcloud tencentcloudstack/terraform-provider-tencentcloud
License
Notes
This Pulumi package is based on the tencentcloud Terraform Provider.