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

opentelekomcloud.DmsTopicV1

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 in the OpenTelekomCloud DMS Service (Kafka Premium/Platinum).

    ~> Deprecated, use opentelekomcloud.DmsTopicV2 resource instead

    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.DmsInstanceV1("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.DmsTopicV1("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.DmsInstanceV1("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.DmsTopicV1("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.NewDmsInstanceV1(ctx, "instance1", &opentelekomcloud.DmsInstanceV1Args{
			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.NewDmsTopicV1(ctx, "topic1", &opentelekomcloud.DmsTopicV1Args{
			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.DmsInstanceV1("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.DmsTopicV1("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.DmsInstanceV1;
import com.pulumi.opentelekomcloud.DmsInstanceV1Args;
import com.pulumi.opentelekomcloud.DmsTopicV1;
import com.pulumi.opentelekomcloud.DmsTopicV1Args;
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 DmsInstanceV1("instance1", DmsInstanceV1Args.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 DmsTopicV1("topic1", DmsTopicV1Args.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:DmsInstanceV1
    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:DmsTopicV1
    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 DmsTopicV1 Resource

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

    Constructor syntax

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

@overload
def DmsTopicV1(resource_name: str,
               opts: Optional[ResourceOptions] = None,
               instance_id: Optional[str] = None,
               dms_topic_v1_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 NewDmsTopicV1(ctx *Context, name string, args DmsTopicV1Args, opts ...ResourceOption) (*DmsTopicV1, error)
    public DmsTopicV1(string name, DmsTopicV1Args args, CustomResourceOptions? opts = null)
    public DmsTopicV1(String name, DmsTopicV1Args args)
public DmsTopicV1(String name, DmsTopicV1Args args, CustomResourceOptions options)

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

    example, err := opentelekomcloud.NewDmsTopicV1(ctx, "dmsTopicV1Resource", &opentelekomcloud.DmsTopicV1Args{
	InstanceId:       pulumi.String("string"),
	DmsTopicV1Id:     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 dmsTopicV1Resource = new DmsTopicV1("dmsTopicV1Resource", DmsTopicV1Args.builder()
    .instanceId("string")
    .dmsTopicV1Id("string")
    .maxPartitions(0)
    .name("string")
    .partition(0)
    .remainPartitions(0)
    .replication(0)
    .retentionTime(0)
    .size(0)
    .syncMessageFlush(false)
    .syncReplication(false)
    .build());

    dms_topic_v1_resource = opentelekomcloud.DmsTopicV1("dmsTopicV1Resource",
    instance_id="string",
    dms_topic_v1_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 dmsTopicV1Resource = new opentelekomcloud.DmsTopicV1("dmsTopicV1Resource", {
    instanceId: "string",
    dmsTopicV1Id: "string",
    maxPartitions: 0,
    name: "string",
    partition: 0,
    remainPartitions: 0,
    replication: 0,
    retentionTime: 0,
    size: 0,
    syncMessageFlush: false,
    syncReplication: false,
});

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

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

    InstanceId string
    Indicates the ID of primary DMS instance.
    DmsTopicV1Id 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–20. 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.
    DmsTopicV1Id 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–20. 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.
    dmsTopicV1Id 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–20. 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.
    dmsTopicV1Id 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–20. 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_v1_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–20. 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.
    dmsTopicV1Id 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–20. 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 DmsTopicV1 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 DmsTopicV1 Resource

    Get an existing DmsTopicV1 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?: DmsTopicV1State, opts?: CustomResourceOptions): DmsTopicV1
    @staticmethod
def get(resource_name: str,
        id: str,
        opts: Optional[ResourceOptions] = None,
        dms_topic_v1_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) -> DmsTopicV1
    func GetDmsTopicV1(ctx *Context, name string, id IDInput, state *DmsTopicV1State, opts ...ResourceOption) (*DmsTopicV1, error)
    public static DmsTopicV1 Get(string name, Input<string> id, DmsTopicV1State? state, CustomResourceOptions? opts = null)
    public static DmsTopicV1 get(String name, Output<String> id, DmsTopicV1State state, CustomResourceOptions options)
    resources:  _:    type: opentelekomcloud:DmsTopicV1    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:
    DmsTopicV1Id 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–20. 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.
    DmsTopicV1Id 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–20. 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.
    dmsTopicV1Id 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–20. 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.
    dmsTopicV1Id 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–20. 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_v1_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–20. 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.
    dmsTopicV1Id 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–20. 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.

    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