Docs Home Pulumi IaC Pulumi ESC Pulumi Insights Pulumi Cloud Packages Tutorials
  1. Packages
  2. Opentelekomcloud Provider
  3. API Docs
  4. DmsTopicV2
opentelekomcloud 1.36.37 published on Thursday, Apr 24, 2025 by opentelekomcloud
opentelekomcloud/terraform-provider-opentelekomcloud

opentelekomcloud.DmsTopicV2

Explore with Pulumi AI

opentelekomcloud logo
opentelekomcloud 1.36.37 published on Thursday, Apr 24, 2025 by opentelekomcloud
opentelekomcloud/terraform-provider-opentelekomcloud

    Up-to-date reference of API arguments for DMS topic you can get at documentation portal

    Manages a DMS topic V2 in the OpenTelekomCloud DMS Service (Kafka Premium/Platinum).

    Example Usage

    Creating Dms Instance With Topic

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

const secgroup1 = new opentelekomcloud.NetworkingSecgroupV2("secgroup1", {description: "secgroup_1"});
const az1 = opentelekomcloud.getDmsAzV1({
    name: "eu-de-01",
});
const product1 = opentelekomcloud.getDmsProductV1({
    engine: "kafka",
    version: "2.3.0",
    instanceType: "cluster",
    partitionNum: "300",
    storage: "600",
    storageSpecCode: "dms.physical.storage.high",
});
const instance1 = new opentelekomcloud.DmsInstanceV2("instance1", {
    engine: "kafka",
    productId: product1.then(product1 => product1.id),
    engineVersion: product1.then(product1 => product1.version),
    specification: product1.then(product1 => product1.bandwidth),
    partitionNum: product1.then(product1 => product1.partitionNum),
    storageSpecCode: product1.then(product1 => product1.storageSpecCode),
    storageSpace: product1.then(product1 => product1.storage),
    availableZones: [az1.then(az1 => az1.id)],
    securityGroupId: secgroup1.networkingSecgroupV2Id,
    vpcId: _var.vpc_id,
    subnetId: _var.subnet_id,
    accessUser: _var.access_user,
    password: _var.password,
});
const topic1 = new opentelekomcloud.DmsTopicV2("topic1", {
    instanceId: resource.opentelekomcloud_dms_instance_v1.instance_1.id,
    partition: 10,
    replication: 2,
    syncReplication: true,
    retentionTime: 80,
});

    import pulumi
import pulumi_opentelekomcloud as opentelekomcloud

secgroup1 = opentelekomcloud.NetworkingSecgroupV2("secgroup1", description="secgroup_1")
az1 = opentelekomcloud.get_dms_az_v1(name="eu-de-01")
product1 = opentelekomcloud.get_dms_product_v1(engine="kafka",
    version="2.3.0",
    instance_type="cluster",
    partition_num="300",
    storage="600",
    storage_spec_code="dms.physical.storage.high")
instance1 = opentelekomcloud.DmsInstanceV2("instance1",
    engine="kafka",
    product_id=product1.id,
    engine_version=product1.version,
    specification=product1.bandwidth,
    partition_num=product1.partition_num,
    storage_spec_code=product1.storage_spec_code,
    storage_space=product1.storage,
    available_zones=[az1.id],
    security_group_id=secgroup1.networking_secgroup_v2_id,
    vpc_id=var["vpc_id"],
    subnet_id=var["subnet_id"],
    access_user=var["access_user"],
    password=var["password"])
topic1 = opentelekomcloud.DmsTopicV2("topic1",
    instance_id=resource["opentelekomcloud_dms_instance_v1"]["instance_1"]["id"],
    partition=10,
    replication=2,
    sync_replication=True,
    retention_time=80)

    package main

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

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		secgroup1, err := opentelekomcloud.NewNetworkingSecgroupV2(ctx, "secgroup1", &opentelekomcloud.NetworkingSecgroupV2Args{
			Description: pulumi.String("secgroup_1"),
		})
		if err != nil {
			return err
		}
		az1, err := opentelekomcloud.GetDmsAzV1(ctx, &opentelekomcloud.GetDmsAzV1Args{
			Name: pulumi.StringRef("eu-de-01"),
		}, nil)
		if err != nil {
			return err
		}
		product1, err := opentelekomcloud.GetDmsProductV1(ctx, &opentelekomcloud.GetDmsProductV1Args{
			Engine:          "kafka",
			Version:         pulumi.StringRef("2.3.0"),
			InstanceType:    "cluster",
			PartitionNum:    pulumi.StringRef("300"),
			Storage:         pulumi.StringRef("600"),
			StorageSpecCode: pulumi.StringRef("dms.physical.storage.high"),
		}, nil)
		if err != nil {
			return err
		}
		_, err = opentelekomcloud.NewDmsInstanceV2(ctx, "instance1", &opentelekomcloud.DmsInstanceV2Args{
			Engine:          pulumi.String("kafka"),
			ProductId:       pulumi.String(product1.Id),
			EngineVersion:   pulumi.String(product1.Version),
			Specification:   pulumi.String(product1.Bandwidth),
			PartitionNum:    pulumi.String(product1.PartitionNum),
			StorageSpecCode: pulumi.String(product1.StorageSpecCode),
			StorageSpace:    pulumi.String(product1.Storage),
			AvailableZones: pulumi.StringArray{
				pulumi.String(az1.Id),
			},
			SecurityGroupId: secgroup1.NetworkingSecgroupV2Id,
			VpcId:           pulumi.Any(_var.Vpc_id),
			SubnetId:        pulumi.Any(_var.Subnet_id),
			AccessUser:      pulumi.Any(_var.Access_user),
			Password:        pulumi.Any(_var.Password),
		})
		if err != nil {
			return err
		}
		_, err = opentelekomcloud.NewDmsTopicV2(ctx, "topic1", &opentelekomcloud.DmsTopicV2Args{
			InstanceId:      pulumi.Any(resource.Opentelekomcloud_dms_instance_v1.Instance_1.Id),
			Partition:       pulumi.Float64(10),
			Replication:     pulumi.Float64(2),
			SyncReplication: pulumi.Bool(true),
			RetentionTime:   pulumi.Float64(80),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

    using System.Collections.Generic;
using System.Linq;
using Pulumi;
using Opentelekomcloud = Pulumi.Opentelekomcloud;

return await Deployment.RunAsync(() => 
{
    var secgroup1 = new Opentelekomcloud.NetworkingSecgroupV2("secgroup1", new()
    {
        Description = "secgroup_1",
    });

    var az1 = Opentelekomcloud.GetDmsAzV1.Invoke(new()
    {
        Name = "eu-de-01",
    });

    var product1 = Opentelekomcloud.GetDmsProductV1.Invoke(new()
    {
        Engine = "kafka",
        Version = "2.3.0",
        InstanceType = "cluster",
        PartitionNum = "300",
        Storage = "600",
        StorageSpecCode = "dms.physical.storage.high",
    });

    var instance1 = new Opentelekomcloud.DmsInstanceV2("instance1", new()
    {
        Engine = "kafka",
        ProductId = product1.Apply(getDmsProductV1Result => getDmsProductV1Result.Id),
        EngineVersion = product1.Apply(getDmsProductV1Result => getDmsProductV1Result.Version),
        Specification = product1.Apply(getDmsProductV1Result => getDmsProductV1Result.Bandwidth),
        PartitionNum = product1.Apply(getDmsProductV1Result => getDmsProductV1Result.PartitionNum),
        StorageSpecCode = product1.Apply(getDmsProductV1Result => getDmsProductV1Result.StorageSpecCode),
        StorageSpace = product1.Apply(getDmsProductV1Result => getDmsProductV1Result.Storage),
        AvailableZones = new[]
        {
            az1.Apply(getDmsAzV1Result => getDmsAzV1Result.Id),
        },
        SecurityGroupId = secgroup1.NetworkingSecgroupV2Id,
        VpcId = @var.Vpc_id,
        SubnetId = @var.Subnet_id,
        AccessUser = @var.Access_user,
        Password = @var.Password,
    });

    var topic1 = new Opentelekomcloud.DmsTopicV2("topic1", new()
    {
        InstanceId = resource.Opentelekomcloud_dms_instance_v1.Instance_1.Id,
        Partition = 10,
        Replication = 2,
        SyncReplication = true,
        RetentionTime = 80,
    });

});

    package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.opentelekomcloud.NetworkingSecgroupV2;
import com.pulumi.opentelekomcloud.NetworkingSecgroupV2Args;
import com.pulumi.opentelekomcloud.OpentelekomcloudFunctions;
import com.pulumi.opentelekomcloud.inputs.GetDmsAzV1Args;
import com.pulumi.opentelekomcloud.inputs.GetDmsProductV1Args;
import com.pulumi.opentelekomcloud.DmsInstanceV2;
import com.pulumi.opentelekomcloud.DmsInstanceV2Args;
import com.pulumi.opentelekomcloud.DmsTopicV2;
import com.pulumi.opentelekomcloud.DmsTopicV2Args;
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) {
        var secgroup1 = new NetworkingSecgroupV2("secgroup1", NetworkingSecgroupV2Args.builder()
            .description("secgroup_1")
            .build());

        final var az1 = OpentelekomcloudFunctions.getDmsAzV1(GetDmsAzV1Args.builder()
            .name("eu-de-01")
            .build());

        final var product1 = OpentelekomcloudFunctions.getDmsProductV1(GetDmsProductV1Args.builder()
            .engine("kafka")
            .version("2.3.0")
            .instanceType("cluster")
            .partitionNum(300)
            .storage(600)
            .storageSpecCode("dms.physical.storage.high")
            .build());

        var instance1 = new DmsInstanceV2("instance1", DmsInstanceV2Args.builder()
            .engine("kafka")
            .productId(product1.applyValue(getDmsProductV1Result -> getDmsProductV1Result.id()))
            .engineVersion(product1.applyValue(getDmsProductV1Result -> getDmsProductV1Result.version()))
            .specification(product1.applyValue(getDmsProductV1Result -> getDmsProductV1Result.bandwidth()))
            .partitionNum(product1.applyValue(getDmsProductV1Result -> getDmsProductV1Result.partitionNum()))
            .storageSpecCode(product1.applyValue(getDmsProductV1Result -> getDmsProductV1Result.storageSpecCode()))
            .storageSpace(product1.applyValue(getDmsProductV1Result -> getDmsProductV1Result.storage()))
            .availableZones(az1.applyValue(getDmsAzV1Result -> getDmsAzV1Result.id()))
            .securityGroupId(secgroup1.networkingSecgroupV2Id())
            .vpcId(var_.vpc_id())
            .subnetId(var_.subnet_id())
            .accessUser(var_.access_user())
            .password(var_.password())
            .build());

        var topic1 = new DmsTopicV2("topic1", DmsTopicV2Args.builder()
            .instanceId(resource.opentelekomcloud_dms_instance_v1().instance_1().id())
            .partition(10)
            .replication(2)
            .syncReplication(true)
            .retentionTime(80)
            .build());

    }
}

    resources:
  secgroup1:
    type: opentelekomcloud:NetworkingSecgroupV2
    properties:
      description: secgroup_1
  instance1:
    type: opentelekomcloud:DmsInstanceV2
    properties:
      engine: kafka
      productId: ${product1.id}
      engineVersion: ${product1.version}
      specification: ${product1.bandwidth}
      partitionNum: ${product1.partitionNum}
      storageSpecCode: ${product1.storageSpecCode}
      storageSpace: ${product1.storage}
      availableZones:
        - ${az1.id}
      securityGroupId: ${secgroup1.networkingSecgroupV2Id}
      vpcId: ${var.vpc_id}
      subnetId: ${var.subnet_id}
      accessUser: ${var.access_user}
      password: ${var.password}
  topic1:
    type: opentelekomcloud:DmsTopicV2
    properties:
      instanceId: ${resource.opentelekomcloud_dms_instance_v1.instance_1.id}
      partition: 10
      replication: 2
      syncReplication: true
      retentionTime: 80
variables:
  az1:
    fn::invoke:
      function: opentelekomcloud:getDmsAzV1
      arguments:
        name: eu-de-01
  product1:
    fn::invoke:
      function: opentelekomcloud:getDmsProductV1
      arguments:
        engine: kafka
        version: 2.3.0
        instanceType: cluster
        partitionNum: 300
        storage: 600
        storageSpecCode: dms.physical.storage.high

    Create DmsTopicV2 Resource

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

    Constructor syntax

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

@overload
def DmsTopicV2(resource_name: str,
               opts: Optional[ResourceOptions] = None,
               instance_id: Optional[str] = None,
               dms_topic_v2_id: Optional[str] = None,
               max_partitions: Optional[float] = None,
               name: Optional[str] = None,
               partition: Optional[float] = None,
               remain_partitions: Optional[float] = None,
               replication: Optional[float] = None,
               retention_time: Optional[float] = None,
               size: Optional[float] = None,
               sync_message_flush: Optional[bool] = None,
               sync_replication: Optional[bool] = None)
    func NewDmsTopicV2(ctx *Context, name string, args DmsTopicV2Args, opts ...ResourceOption) (*DmsTopicV2, error)
    public DmsTopicV2(string name, DmsTopicV2Args args, CustomResourceOptions? opts = null)
    public DmsTopicV2(String name, DmsTopicV2Args args)
public DmsTopicV2(String name, DmsTopicV2Args args, CustomResourceOptions options)

    type: opentelekomcloud:DmsTopicV2
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 DmsTopicV2Args
    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 DmsTopicV2Args
    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 DmsTopicV2Args
    The arguments to resource properties.
    opts ResourceOption
    Bag of options to control resource's behavior.
    name string
    The unique name of the resource.
    args DmsTopicV2Args
    The arguments to resource properties.
    opts CustomResourceOptions
    Bag of options to control resource's behavior.
    name String
    The unique name of the resource.
    args DmsTopicV2Args
    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 dmsTopicV2Resource = new Opentelekomcloud.DmsTopicV2("dmsTopicV2Resource", new()
{
    InstanceId = "string",
    DmsTopicV2Id = "string",
    MaxPartitions = 0,
    Name = "string",
    Partition = 0,
    RemainPartitions = 0,
    Replication = 0,
    RetentionTime = 0,
    Size = 0,
    SyncMessageFlush = false,
    SyncReplication = false,
});

    example, err := opentelekomcloud.NewDmsTopicV2(ctx, "dmsTopicV2Resource", &opentelekomcloud.DmsTopicV2Args{
	InstanceId:       pulumi.String("string"),
	DmsTopicV2Id:     pulumi.String("string"),
	MaxPartitions:    pulumi.Float64(0),
	Name:             pulumi.String("string"),
	Partition:        pulumi.Float64(0),
	RemainPartitions: pulumi.Float64(0),
	Replication:      pulumi.Float64(0),
	RetentionTime:    pulumi.Float64(0),
	Size:             pulumi.Float64(0),
	SyncMessageFlush: pulumi.Bool(false),
	SyncReplication:  pulumi.Bool(false),
})

    var dmsTopicV2Resource = new DmsTopicV2("dmsTopicV2Resource", DmsTopicV2Args.builder()
    .instanceId("string")
    .dmsTopicV2Id("string")
    .maxPartitions(0)
    .name("string")
    .partition(0)
    .remainPartitions(0)
    .replication(0)
    .retentionTime(0)
    .size(0)
    .syncMessageFlush(false)
    .syncReplication(false)
    .build());

    dms_topic_v2_resource = opentelekomcloud.DmsTopicV2("dmsTopicV2Resource",
    instance_id="string",
    dms_topic_v2_id="string",
    max_partitions=0,
    name="string",
    partition=0,
    remain_partitions=0,
    replication=0,
    retention_time=0,
    size=0,
    sync_message_flush=False,
    sync_replication=False)

    const dmsTopicV2Resource = new opentelekomcloud.DmsTopicV2("dmsTopicV2Resource", {
    instanceId: "string",
    dmsTopicV2Id: "string",
    maxPartitions: 0,
    name: "string",
    partition: 0,
    remainPartitions: 0,
    replication: 0,
    retentionTime: 0,
    size: 0,
    syncMessageFlush: false,
    syncReplication: false,
});

    type: opentelekomcloud:DmsTopicV2
properties:
    dmsTopicV2Id: string
    instanceId: string
    maxPartitions: 0
    name: string
    partition: 0
    remainPartitions: 0
    replication: 0
    retentionTime: 0
    size: 0
    syncMessageFlush: false
    syncReplication: false

    DmsTopicV2 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 DmsTopicV2 resource accepts the following input properties:

    InstanceId string
    Indicates the ID of primary DMS instance.
    DmsTopicV2Id string
    MaxPartitions double
    Total partitions number.
    Name string
    Indicates the name of a topic.
    Partition double
    Indicates the number of topic partitions, which is used to set the number of concurrently consumed messages. Value range: 1–200. Default value: 3.
    RemainPartitions double
    Number of remaining partitions.
    Replication double
    Indicates the number of replicas, which is configured to ensure data reliability. Value range: 1–3. Default value: 3.
    RetentionTime double
    Indicates the retention period of a message. Its default value is 72. Value range: 1–720. Default value: 72. Unit: hour.
    Size double
    The partition size of the topic.
    SyncMessageFlush bool
    Indicates whether to enable synchronous flushing. Default value: false. Synchronous flushing compromises performance.
    SyncReplication bool
    Indicates whether to enable synchronous replication. After this function is enabled, the acks parameter on the producer client must be set to –1. Otherwise, this parameter does not take effect.
    InstanceId string
    Indicates the ID of primary DMS instance.
    DmsTopicV2Id string
    MaxPartitions float64
    Total partitions number.
    Name string
    Indicates the name of a topic.
    Partition float64
    Indicates the number of topic partitions, which is used to set the number of concurrently consumed messages. Value range: 1–200. Default value: 3.
    RemainPartitions float64
    Number of remaining partitions.
    Replication float64
    Indicates the number of replicas, which is configured to ensure data reliability. Value range: 1–3. Default value: 3.
    RetentionTime float64
    Indicates the retention period of a message. Its default value is 72. Value range: 1–720. Default value: 72. Unit: hour.
    Size float64
    The partition size of the topic.
    SyncMessageFlush bool
    Indicates whether to enable synchronous flushing. Default value: false. Synchronous flushing compromises performance.
    SyncReplication bool
    Indicates whether to enable synchronous replication. After this function is enabled, the acks parameter on the producer client must be set to –1. Otherwise, this parameter does not take effect.
    instanceId String
    Indicates the ID of primary DMS instance.
    dmsTopicV2Id String
    maxPartitions Double
    Total partitions number.
    name String
    Indicates the name of a topic.
    partition Double
    Indicates the number of topic partitions, which is used to set the number of concurrently consumed messages. Value range: 1–200. Default value: 3.
    remainPartitions Double
    Number of remaining partitions.
    replication Double
    Indicates the number of replicas, which is configured to ensure data reliability. Value range: 1–3. Default value: 3.
    retentionTime Double
    Indicates the retention period of a message. Its default value is 72. Value range: 1–720. Default value: 72. Unit: hour.
    size Double
    The partition size of the topic.
    syncMessageFlush Boolean
    Indicates whether to enable synchronous flushing. Default value: false. Synchronous flushing compromises performance.
    syncReplication Boolean
    Indicates whether to enable synchronous replication. After this function is enabled, the acks parameter on the producer client must be set to –1. Otherwise, this parameter does not take effect.
    instanceId string
    Indicates the ID of primary DMS instance.
    dmsTopicV2Id string
    maxPartitions number
    Total partitions number.
    name string
    Indicates the name of a topic.
    partition number
    Indicates the number of topic partitions, which is used to set the number of concurrently consumed messages. Value range: 1–200. Default value: 3.
    remainPartitions number
    Number of remaining partitions.
    replication number
    Indicates the number of replicas, which is configured to ensure data reliability. Value range: 1–3. Default value: 3.
    retentionTime number
    Indicates the retention period of a message. Its default value is 72. Value range: 1–720. Default value: 72. Unit: hour.
    size number
    The partition size of the topic.
    syncMessageFlush boolean
    Indicates whether to enable synchronous flushing. Default value: false. Synchronous flushing compromises performance.
    syncReplication boolean
    Indicates whether to enable synchronous replication. After this function is enabled, the acks parameter on the producer client must be set to –1. Otherwise, this parameter does not take effect.
    instance_id str
    Indicates the ID of primary DMS instance.
    dms_topic_v2_id str
    max_partitions float
    Total partitions number.
    name str
    Indicates the name of a topic.
    partition float
    Indicates the number of topic partitions, which is used to set the number of concurrently consumed messages. Value range: 1–200. Default value: 3.
    remain_partitions float
    Number of remaining partitions.
    replication float
    Indicates the number of replicas, which is configured to ensure data reliability. Value range: 1–3. Default value: 3.
    retention_time float
    Indicates the retention period of a message. Its default value is 72. Value range: 1–720. Default value: 72. Unit: hour.
    size float
    The partition size of the topic.
    sync_message_flush bool
    Indicates whether to enable synchronous flushing. Default value: false. Synchronous flushing compromises performance.
    sync_replication bool
    Indicates whether to enable synchronous replication. After this function is enabled, the acks parameter on the producer client must be set to –1. Otherwise, this parameter does not take effect.
    instanceId String
    Indicates the ID of primary DMS instance.
    dmsTopicV2Id String
    maxPartitions Number
    Total partitions number.
    name String
    Indicates the name of a topic.
    partition Number
    Indicates the number of topic partitions, which is used to set the number of concurrently consumed messages. Value range: 1–200. Default value: 3.
    remainPartitions Number
    Number of remaining partitions.
    replication Number
    Indicates the number of replicas, which is configured to ensure data reliability. Value range: 1–3. Default value: 3.
    retentionTime Number
    Indicates the retention period of a message. Its default value is 72. Value range: 1–720. Default value: 72. Unit: hour.
    size Number
    The partition size of the topic.
    syncMessageFlush Boolean
    Indicates whether to enable synchronous flushing. Default value: false. Synchronous flushing compromises performance.
    syncReplication Boolean
    Indicates whether to enable synchronous replication. After this function is enabled, the acks parameter on the producer client must be set to –1. Otherwise, this parameter does not take effect.

    Outputs

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

    Id string
    The provider-assigned unique ID for this managed resource.
    Id string
    The provider-assigned unique ID for this managed resource.
    id String
    The provider-assigned unique ID for this managed resource.
    id string
    The provider-assigned unique ID for this managed resource.
    id str
    The provider-assigned unique ID for this managed resource.
    id String
    The provider-assigned unique ID for this managed resource.

    Look up Existing DmsTopicV2 Resource

    Get an existing DmsTopicV2 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?: DmsTopicV2State, opts?: CustomResourceOptions): DmsTopicV2
    @staticmethod
def get(resource_name: str,
        id: str,
        opts: Optional[ResourceOptions] = None,
        dms_topic_v2_id: Optional[str] = None,
        instance_id: Optional[str] = None,
        max_partitions: Optional[float] = None,
        name: Optional[str] = None,
        partition: Optional[float] = None,
        remain_partitions: Optional[float] = None,
        replication: Optional[float] = None,
        retention_time: Optional[float] = None,
        size: Optional[float] = None,
        sync_message_flush: Optional[bool] = None,
        sync_replication: Optional[bool] = None) -> DmsTopicV2
    func GetDmsTopicV2(ctx *Context, name string, id IDInput, state *DmsTopicV2State, opts ...ResourceOption) (*DmsTopicV2, error)
    public static DmsTopicV2 Get(string name, Input<string> id, DmsTopicV2State? state, CustomResourceOptions? opts = null)
    public static DmsTopicV2 get(String name, Output<String> id, DmsTopicV2State state, CustomResourceOptions options)
    resources:  _:    type: opentelekomcloud:DmsTopicV2    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:
    DmsTopicV2Id string
    InstanceId string
    Indicates the ID of primary DMS instance.
    MaxPartitions double
    Total partitions number.
    Name string
    Indicates the name of a topic.
    Partition double
    Indicates the number of topic partitions, which is used to set the number of concurrently consumed messages. Value range: 1–200. Default value: 3.
    RemainPartitions double
    Number of remaining partitions.
    Replication double
    Indicates the number of replicas, which is configured to ensure data reliability. Value range: 1–3. Default value: 3.
    RetentionTime double
    Indicates the retention period of a message. Its default value is 72. Value range: 1–720. Default value: 72. Unit: hour.
    Size double
    The partition size of the topic.
    SyncMessageFlush bool
    Indicates whether to enable synchronous flushing. Default value: false. Synchronous flushing compromises performance.
    SyncReplication bool
    Indicates whether to enable synchronous replication. After this function is enabled, the acks parameter on the producer client must be set to –1. Otherwise, this parameter does not take effect.
    DmsTopicV2Id string
    InstanceId string
    Indicates the ID of primary DMS instance.
    MaxPartitions float64
    Total partitions number.
    Name string
    Indicates the name of a topic.
    Partition float64
    Indicates the number of topic partitions, which is used to set the number of concurrently consumed messages. Value range: 1–200. Default value: 3.
    RemainPartitions float64
    Number of remaining partitions.
    Replication float64
    Indicates the number of replicas, which is configured to ensure data reliability. Value range: 1–3. Default value: 3.
    RetentionTime float64
    Indicates the retention period of a message. Its default value is 72. Value range: 1–720. Default value: 72. Unit: hour.
    Size float64
    The partition size of the topic.
    SyncMessageFlush bool
    Indicates whether to enable synchronous flushing. Default value: false. Synchronous flushing compromises performance.
    SyncReplication bool
    Indicates whether to enable synchronous replication. After this function is enabled, the acks parameter on the producer client must be set to –1. Otherwise, this parameter does not take effect.
    dmsTopicV2Id String
    instanceId String
    Indicates the ID of primary DMS instance.
    maxPartitions Double
    Total partitions number.
    name String
    Indicates the name of a topic.
    partition Double
    Indicates the number of topic partitions, which is used to set the number of concurrently consumed messages. Value range: 1–200. Default value: 3.
    remainPartitions Double
    Number of remaining partitions.
    replication Double
    Indicates the number of replicas, which is configured to ensure data reliability. Value range: 1–3. Default value: 3.
    retentionTime Double
    Indicates the retention period of a message. Its default value is 72. Value range: 1–720. Default value: 72. Unit: hour.
    size Double
    The partition size of the topic.
    syncMessageFlush Boolean
    Indicates whether to enable synchronous flushing. Default value: false. Synchronous flushing compromises performance.
    syncReplication Boolean
    Indicates whether to enable synchronous replication. After this function is enabled, the acks parameter on the producer client must be set to –1. Otherwise, this parameter does not take effect.
    dmsTopicV2Id string
    instanceId string
    Indicates the ID of primary DMS instance.
    maxPartitions number
    Total partitions number.
    name string
    Indicates the name of a topic.
    partition number
    Indicates the number of topic partitions, which is used to set the number of concurrently consumed messages. Value range: 1–200. Default value: 3.
    remainPartitions number
    Number of remaining partitions.
    replication number
    Indicates the number of replicas, which is configured to ensure data reliability. Value range: 1–3. Default value: 3.
    retentionTime number
    Indicates the retention period of a message. Its default value is 72. Value range: 1–720. Default value: 72. Unit: hour.
    size number
    The partition size of the topic.
    syncMessageFlush boolean
    Indicates whether to enable synchronous flushing. Default value: false. Synchronous flushing compromises performance.
    syncReplication boolean
    Indicates whether to enable synchronous replication. After this function is enabled, the acks parameter on the producer client must be set to –1. Otherwise, this parameter does not take effect.
    dms_topic_v2_id str
    instance_id str
    Indicates the ID of primary DMS instance.
    max_partitions float
    Total partitions number.
    name str
    Indicates the name of a topic.
    partition float
    Indicates the number of topic partitions, which is used to set the number of concurrently consumed messages. Value range: 1–200. Default value: 3.
    remain_partitions float
    Number of remaining partitions.
    replication float
    Indicates the number of replicas, which is configured to ensure data reliability. Value range: 1–3. Default value: 3.
    retention_time float
    Indicates the retention period of a message. Its default value is 72. Value range: 1–720. Default value: 72. Unit: hour.
    size float
    The partition size of the topic.
    sync_message_flush bool
    Indicates whether to enable synchronous flushing. Default value: false. Synchronous flushing compromises performance.
    sync_replication bool
    Indicates whether to enable synchronous replication. After this function is enabled, the acks parameter on the producer client must be set to –1. Otherwise, this parameter does not take effect.
    dmsTopicV2Id String
    instanceId String
    Indicates the ID of primary DMS instance.
    maxPartitions Number
    Total partitions number.
    name String
    Indicates the name of a topic.
    partition Number
    Indicates the number of topic partitions, which is used to set the number of concurrently consumed messages. Value range: 1–200. Default value: 3.
    remainPartitions Number
    Number of remaining partitions.
    replication Number
    Indicates the number of replicas, which is configured to ensure data reliability. Value range: 1–3. Default value: 3.
    retentionTime Number
    Indicates the retention period of a message. Its default value is 72. Value range: 1–720. Default value: 72. Unit: hour.
    size Number
    The partition size of the topic.
    syncMessageFlush Boolean
    Indicates whether to enable synchronous flushing. Default value: false. Synchronous flushing compromises performance.
    syncReplication Boolean
    Indicates whether to enable synchronous replication. After this function is enabled, the acks parameter on the producer client must be set to –1. Otherwise, this parameter does not take effect.

    Import

    DMS topics can be imported using their topic_name and related instance_id, separated by a slash, e.g.

    bash

    $ pulumi import opentelekomcloud:index/dmsTopicV2:DmsTopicV2 test_topic <instance_id>/<topic_name>

    To learn more about importing existing cloud resources, see Importing resources.

    Package Details

    Repository
    opentelekomcloud opentelekomcloud/terraform-provider-opentelekomcloud
    License
    Notes
    This Pulumi package is based on the opentelekomcloud Terraform Provider.
    opentelekomcloud logo
    opentelekomcloud 1.36.37 published on Thursday, Apr 24, 2025 by opentelekomcloud
    opentelekomcloud/terraform-provider-opentelekomcloud