Sign in Dashboard Get started
  1. Registry
  2. Packages
  3. Opentelekomcloud Provider
  4. API Docs
  5. DmsRocketmqMigrationTaskV2
Viewing docs for opentelekomcloud 1.37.11
published on Friday, Oct 23, 2026 by opentelekomcloud
Schema (JSON)
opentelekomcloud/terraform-provider-opentelekomcloud

opentelekomcloud.DmsRocketmqMigrationTaskV2

opentelekomcloud
Viewing docs for opentelekomcloud 1.37.11
published on Friday, Oct 23, 2026 by opentelekomcloud
Schema (JSON)
opentelekomcloud/terraform-provider-opentelekomcloud

    Up-to-date reference of API arguments for DMS RocketMQ metadata migration task you can get at documentation portal

    Manages a DMS RocketMQ metadata migration task in the OpenTelekomCloud DMS Service. The task migrates metadata of a self-built RocketMQ or RabbitMQ instance to a DMS RocketMQ instance. The resource waits until the task is finished.

    Deleting the resource deletes only the task, the migrated topics and consumer groups stay in the instance.

    Example Usage

    Migrating metadata from RocketMQ

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

const config = new pulumi.Config();
const instanceId = config.requireObject<any>("instanceId");
const test = new opentelekomcloud.DmsRocketmqMigrationTaskV2("test", {
    instanceId: instanceId,
    name: "task_test",
    type: "rocketmq",
    overwrite: true,
    topicConfigs: [{
        topicName: "topic_test",
        perm: 6,
        readQueueNums: 3,
        writeQueueNums: 3,
        topicFilterType: "SINGLE_TAG",
    }],
    subscriptionGroups: [{
        groupName: "group_test",
        retryMaxTimes: 2,
    }],
});

    import pulumi
import pulumi_opentelekomcloud as opentelekomcloud

config = pulumi.Config()
instance_id = config.require_object("instanceId")
test = opentelekomcloud.DmsRocketmqMigrationTaskV2("test",
    instance_id=instance_id,
    name="task_test",
    type="rocketmq",
    overwrite=True,
    topic_configs=[{
        "topic_name": "topic_test",
        "perm": 6,
        "read_queue_nums": 3,
        "write_queue_nums": 3,
        "topic_filter_type": "SINGLE_TAG",
    }],
    subscription_groups=[{
        "group_name": "group_test",
        "retry_max_times": 2,
    }])

    package main

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

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		cfg := config.New(ctx, "")
		instanceId := cfg.RequireObject("instanceId")
		_, err := opentelekomcloud.NewDmsRocketmqMigrationTaskV2(ctx, "test", &opentelekomcloud.DmsRocketmqMigrationTaskV2Args{
			InstanceId: pulumi.Any(instanceId),
			Name:       pulumi.String("task_test"),
			Type:       pulumi.String("rocketmq"),
			Overwrite:  pulumi.Bool(true),
			TopicConfigs: opentelekomcloud.DmsRocketmqMigrationTaskV2TopicConfigArray{
				&opentelekomcloud.DmsRocketmqMigrationTaskV2TopicConfigArgs{
					TopicName:       pulumi.String("topic_test"),
					Perm:            pulumi.Float64(6),
					ReadQueueNums:   pulumi.Float64(3),
					WriteQueueNums:  pulumi.Float64(3),
					TopicFilterType: pulumi.String("SINGLE_TAG"),
				},
			},
			SubscriptionGroups: opentelekomcloud.DmsRocketmqMigrationTaskV2SubscriptionGroupArray{
				&opentelekomcloud.DmsRocketmqMigrationTaskV2SubscriptionGroupArgs{
					GroupName:     pulumi.String("group_test"),
					RetryMaxTimes: pulumi.Float64(2),
				},
			},
		})
		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 config = new Config();
    var instanceId = config.RequireObject<dynamic>("instanceId");
    var test = new Opentelekomcloud.DmsRocketmqMigrationTaskV2("test", new()
    {
        InstanceId = instanceId,
        Name = "task_test",
        Type = "rocketmq",
        Overwrite = true,
        TopicConfigs = new[]
        {
            new Opentelekomcloud.Inputs.DmsRocketmqMigrationTaskV2TopicConfigArgs
            {
                TopicName = "topic_test",
                Perm = 6,
                ReadQueueNums = 3,
                WriteQueueNums = 3,
                TopicFilterType = "SINGLE_TAG",
            },
        },
        SubscriptionGroups = new[]
        {
            new Opentelekomcloud.Inputs.DmsRocketmqMigrationTaskV2SubscriptionGroupArgs
            {
                GroupName = "group_test",
                RetryMaxTimes = 2,
            },
        },
    });

});

    package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.opentelekomcloud.DmsRocketmqMigrationTaskV2;
import com.pulumi.opentelekomcloud.DmsRocketmqMigrationTaskV2Args;
import com.pulumi.opentelekomcloud.inputs.DmsRocketmqMigrationTaskV2TopicConfigArgs;
import com.pulumi.opentelekomcloud.inputs.DmsRocketmqMigrationTaskV2SubscriptionGroupArgs;
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 config = ctx.config();
        final var instanceId = config.get("instanceId");
        var test = new DmsRocketmqMigrationTaskV2("test", DmsRocketmqMigrationTaskV2Args.builder()
            .instanceId(instanceId)
            .name("task_test")
            .type("rocketmq")
            .overwrite(true)
            .topicConfigs(DmsRocketmqMigrationTaskV2TopicConfigArgs.builder()
                .topicName("topic_test")
                .perm(6.0)
                .readQueueNums(3.0)
                .writeQueueNums(3.0)
                .topicFilterType("SINGLE_TAG")
                .build())
            .subscriptionGroups(DmsRocketmqMigrationTaskV2SubscriptionGroupArgs.builder()
                .groupName("group_test")
                .retryMaxTimes(2.0)
                .build())
            .build());

    }
}

    configuration:
  instanceId:
    type: dynamic
resources:
  test:
    type: opentelekomcloud:DmsRocketmqMigrationTaskV2
    properties:
      instanceId: ${instanceId}
      name: task_test
      type: rocketmq
      overwrite: true
      topicConfigs:
        - topicName: topic_test
          perm: 6
          readQueueNums: 3
          writeQueueNums: 3
          topicFilterType: SINGLE_TAG
      subscriptionGroups:
        - groupName: group_test
          retryMaxTimes: 2

    Example coming soon!

    Migrating metadata from RabbitMQ

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

const config = new pulumi.Config();
const instanceId = config.requireObject<any>("instanceId");
const test = new opentelekomcloud.DmsRocketmqMigrationTaskV2("test", {
    instanceId: instanceId,
    name: "task_test",
    type: "rabbitToRocket",
    vhosts: [{
        name: "vhost_test",
    }],
    queues: [{
        vhost: "vhost_test",
        name: "queue_test",
        durable: true,
    }],
    exchanges: [{
        vhost: "vhost_test",
        name: "exchange_test",
        type: "direct",
        durable: true,
    }],
    bindings: [{
        vhost: "vhost_test",
        source: "exchange_test",
        destination: "queue_test",
        destinationType: "queue",
        routingKey: "routing_key_test",
    }],
});

    import pulumi
import pulumi_opentelekomcloud as opentelekomcloud

config = pulumi.Config()
instance_id = config.require_object("instanceId")
test = opentelekomcloud.DmsRocketmqMigrationTaskV2("test",
    instance_id=instance_id,
    name="task_test",
    type="rabbitToRocket",
    vhosts=[{
        "name": "vhost_test",
    }],
    queues=[{
        "vhost": "vhost_test",
        "name": "queue_test",
        "durable": True,
    }],
    exchanges=[{
        "vhost": "vhost_test",
        "name": "exchange_test",
        "type": "direct",
        "durable": True,
    }],
    bindings=[{
        "vhost": "vhost_test",
        "source": "exchange_test",
        "destination": "queue_test",
        "destination_type": "queue",
        "routing_key": "routing_key_test",
    }])

    package main

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

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		cfg := config.New(ctx, "")
		instanceId := cfg.RequireObject("instanceId")
		_, err := opentelekomcloud.NewDmsRocketmqMigrationTaskV2(ctx, "test", &opentelekomcloud.DmsRocketmqMigrationTaskV2Args{
			InstanceId: pulumi.Any(instanceId),
			Name:       pulumi.String("task_test"),
			Type:       pulumi.String("rabbitToRocket"),
			Vhosts: opentelekomcloud.DmsRocketmqMigrationTaskV2VhostArray{
				&opentelekomcloud.DmsRocketmqMigrationTaskV2VhostArgs{
					Name: pulumi.String("vhost_test"),
				},
			},
			Queues: opentelekomcloud.DmsRocketmqMigrationTaskV2QueueArray{
				&opentelekomcloud.DmsRocketmqMigrationTaskV2QueueArgs{
					Vhost:   pulumi.String("vhost_test"),
					Name:    pulumi.String("queue_test"),
					Durable: pulumi.Bool(true),
				},
			},
			Exchanges: opentelekomcloud.DmsRocketmqMigrationTaskV2ExchangeArray{
				&opentelekomcloud.DmsRocketmqMigrationTaskV2ExchangeArgs{
					Vhost:   pulumi.String("vhost_test"),
					Name:    pulumi.String("exchange_test"),
					Type:    pulumi.String("direct"),
					Durable: pulumi.Bool(true),
				},
			},
			Bindings: opentelekomcloud.DmsRocketmqMigrationTaskV2BindingArray{
				&opentelekomcloud.DmsRocketmqMigrationTaskV2BindingArgs{
					Vhost:           pulumi.String("vhost_test"),
					Source:          pulumi.String("exchange_test"),
					Destination:     pulumi.String("queue_test"),
					DestinationType: pulumi.String("queue"),
					RoutingKey:      pulumi.String("routing_key_test"),
				},
			},
		})
		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 config = new Config();
    var instanceId = config.RequireObject<dynamic>("instanceId");
    var test = new Opentelekomcloud.DmsRocketmqMigrationTaskV2("test", new()
    {
        InstanceId = instanceId,
        Name = "task_test",
        Type = "rabbitToRocket",
        Vhosts = new[]
        {
            new Opentelekomcloud.Inputs.DmsRocketmqMigrationTaskV2VhostArgs
            {
                Name = "vhost_test",
            },
        },
        Queues = new[]
        {
            new Opentelekomcloud.Inputs.DmsRocketmqMigrationTaskV2QueueArgs
            {
                Vhost = "vhost_test",
                Name = "queue_test",
                Durable = true,
            },
        },
        Exchanges = new[]
        {
            new Opentelekomcloud.Inputs.DmsRocketmqMigrationTaskV2ExchangeArgs
            {
                Vhost = "vhost_test",
                Name = "exchange_test",
                Type = "direct",
                Durable = true,
            },
        },
        Bindings = new[]
        {
            new Opentelekomcloud.Inputs.DmsRocketmqMigrationTaskV2BindingArgs
            {
                Vhost = "vhost_test",
                Source = "exchange_test",
                Destination = "queue_test",
                DestinationType = "queue",
                RoutingKey = "routing_key_test",
            },
        },
    });

});

    package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.opentelekomcloud.DmsRocketmqMigrationTaskV2;
import com.pulumi.opentelekomcloud.DmsRocketmqMigrationTaskV2Args;
import com.pulumi.opentelekomcloud.inputs.DmsRocketmqMigrationTaskV2VhostArgs;
import com.pulumi.opentelekomcloud.inputs.DmsRocketmqMigrationTaskV2QueueArgs;
import com.pulumi.opentelekomcloud.inputs.DmsRocketmqMigrationTaskV2ExchangeArgs;
import com.pulumi.opentelekomcloud.inputs.DmsRocketmqMigrationTaskV2BindingArgs;
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 config = ctx.config();
        final var instanceId = config.get("instanceId");
        var test = new DmsRocketmqMigrationTaskV2("test", DmsRocketmqMigrationTaskV2Args.builder()
            .instanceId(instanceId)
            .name("task_test")
            .type("rabbitToRocket")
            .vhosts(DmsRocketmqMigrationTaskV2VhostArgs.builder()
                .name("vhost_test")
                .build())
            .queues(DmsRocketmqMigrationTaskV2QueueArgs.builder()
                .vhost("vhost_test")
                .name("queue_test")
                .durable(true)
                .build())
            .exchanges(DmsRocketmqMigrationTaskV2ExchangeArgs.builder()
                .vhost("vhost_test")
                .name("exchange_test")
                .type("direct")
                .durable(true)
                .build())
            .bindings(DmsRocketmqMigrationTaskV2BindingArgs.builder()
                .vhost("vhost_test")
                .source("exchange_test")
                .destination("queue_test")
                .destinationType("queue")
                .routingKey("routing_key_test")
                .build())
            .build());

    }
}

    configuration:
  instanceId:
    type: dynamic
resources:
  test:
    type: opentelekomcloud:DmsRocketmqMigrationTaskV2
    properties:
      instanceId: ${instanceId}
      name: task_test
      type: rabbitToRocket
      vhosts:
        - name: vhost_test
      queues:
        - vhost: vhost_test
          name: queue_test
          durable: true
      exchanges:
        - vhost: vhost_test
          name: exchange_test
          type: direct
          durable: true
      bindings:
        - vhost: vhost_test
          source: exchange_test
          destination: queue_test
          destinationType: queue
          routingKey: routing_key_test

    Example coming soon!

    Create DmsRocketmqMigrationTaskV2 Resource

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

    Constructor syntax

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

@overload
def DmsRocketmqMigrationTaskV2(resource_name: str,
                               opts: Optional[ResourceOptions] = None,
                               instance_id: Optional[str] = None,
                               type: Optional[str] = None,
                               bindings: Optional[Sequence[DmsRocketmqMigrationTaskV2BindingArgs]] = None,
                               dms_rocketmq_migration_task_v2_id: Optional[str] = None,
                               exchanges: Optional[Sequence[DmsRocketmqMigrationTaskV2ExchangeArgs]] = None,
                               name: Optional[str] = None,
                               overwrite: Optional[bool] = None,
                               queues: Optional[Sequence[DmsRocketmqMigrationTaskV2QueueArgs]] = None,
                               subscription_groups: Optional[Sequence[DmsRocketmqMigrationTaskV2SubscriptionGroupArgs]] = None,
                               timeouts: Optional[DmsRocketmqMigrationTaskV2TimeoutsArgs] = None,
                               topic_configs: Optional[Sequence[DmsRocketmqMigrationTaskV2TopicConfigArgs]] = None,
                               vhosts: Optional[Sequence[DmsRocketmqMigrationTaskV2VhostArgs]] = None)
    func NewDmsRocketmqMigrationTaskV2(ctx *Context, name string, args DmsRocketmqMigrationTaskV2Args, opts ...ResourceOption) (*DmsRocketmqMigrationTaskV2, error)
    public DmsRocketmqMigrationTaskV2(string name, DmsRocketmqMigrationTaskV2Args args, CustomResourceOptions? opts = null)
    public DmsRocketmqMigrationTaskV2(String name, DmsRocketmqMigrationTaskV2Args args)
public DmsRocketmqMigrationTaskV2(String name, DmsRocketmqMigrationTaskV2Args args, CustomResourceOptions options)

    type: opentelekomcloud:DmsRocketmqMigrationTaskV2
properties: # The arguments to resource properties.
options: # Bag of options to control resource's behavior.


    resource "opentelekomcloud_dms_rocketmq_migration_task_v2" "name" {
    # resource properties
}

    Parameters

    name string
    The unique name of the resource.
    args DmsRocketmqMigrationTaskV2Args
    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 DmsRocketmqMigrationTaskV2Args
    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 DmsRocketmqMigrationTaskV2Args
    The arguments to resource properties.
    opts ResourceOption
    Bag of options to control resource's behavior.
    name string
    The unique name of the resource.
    args DmsRocketmqMigrationTaskV2Args
    The arguments to resource properties.
    opts CustomResourceOptions
    Bag of options to control resource's behavior.
    name String
    The unique name of the resource.
    args DmsRocketmqMigrationTaskV2Args
    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 dmsRocketmqMigrationTaskV2Resource = new Opentelekomcloud.DmsRocketmqMigrationTaskV2("dmsRocketmqMigrationTaskV2Resource", new()
{
    InstanceId = "string",
    Type = "string",
    Bindings = new[]
    {
        new Opentelekomcloud.Inputs.DmsRocketmqMigrationTaskV2BindingArgs
        {
            Destination = "string",
            DestinationType = "string",
            RoutingKey = "string",
            Source = "string",
            Vhost = "string",
        },
    },
    DmsRocketmqMigrationTaskV2Id = "string",
    Exchanges = new[]
    {
        new Opentelekomcloud.Inputs.DmsRocketmqMigrationTaskV2ExchangeArgs
        {
            Durable = false,
            Name = "string",
            Type = "string",
            Vhost = "string",
        },
    },
    Name = "string",
    Overwrite = false,
    Queues = new[]
    {
        new Opentelekomcloud.Inputs.DmsRocketmqMigrationTaskV2QueueArgs
        {
            Durable = false,
            Name = "string",
            Vhost = "string",
        },
    },
    SubscriptionGroups = new[]
    {
        new Opentelekomcloud.Inputs.DmsRocketmqMigrationTaskV2SubscriptionGroupArgs
        {
            GroupName = "string",
            ConsumeBroadcastEnable = false,
            ConsumeEnable = false,
            ConsumeFromMinEnable = false,
            NotifyConsumerIdsChangedEnable = false,
            RetryMaxTimes = 0.0,
            RetryQueueNums = 0.0,
            WhichBrokerWhenConsumeSlow = 0.0,
        },
    },
    Timeouts = new Opentelekomcloud.Inputs.DmsRocketmqMigrationTaskV2TimeoutsArgs
    {
        Create = "string",
    },
    TopicConfigs = new[]
    {
        new Opentelekomcloud.Inputs.DmsRocketmqMigrationTaskV2TopicConfigArgs
        {
            TopicName = "string",
            Order = false,
            Perm = 0.0,
            ReadQueueNums = 0.0,
            TopicFilterType = "string",
            TopicSysFlag = 0.0,
            WriteQueueNums = 0.0,
        },
    },
    Vhosts = new[]
    {
        new Opentelekomcloud.Inputs.DmsRocketmqMigrationTaskV2VhostArgs
        {
            Name = "string",
        },
    },
});

    example, err := opentelekomcloud.NewDmsRocketmqMigrationTaskV2(ctx, "dmsRocketmqMigrationTaskV2Resource", &opentelekomcloud.DmsRocketmqMigrationTaskV2Args{
	InstanceId: pulumi.String("string"),
	Type:       pulumi.String("string"),
	Bindings: opentelekomcloud.DmsRocketmqMigrationTaskV2BindingArray{
		&opentelekomcloud.DmsRocketmqMigrationTaskV2BindingArgs{
			Destination:     pulumi.String("string"),
			DestinationType: pulumi.String("string"),
			RoutingKey:      pulumi.String("string"),
			Source:          pulumi.String("string"),
			Vhost:           pulumi.String("string"),
		},
	},
	DmsRocketmqMigrationTaskV2Id: pulumi.String("string"),
	Exchanges: opentelekomcloud.DmsRocketmqMigrationTaskV2ExchangeArray{
		&opentelekomcloud.DmsRocketmqMigrationTaskV2ExchangeArgs{
			Durable: pulumi.Bool(false),
			Name:    pulumi.String("string"),
			Type:    pulumi.String("string"),
			Vhost:   pulumi.String("string"),
		},
	},
	Name:      pulumi.String("string"),
	Overwrite: pulumi.Bool(false),
	Queues: opentelekomcloud.DmsRocketmqMigrationTaskV2QueueArray{
		&opentelekomcloud.DmsRocketmqMigrationTaskV2QueueArgs{
			Durable: pulumi.Bool(false),
			Name:    pulumi.String("string"),
			Vhost:   pulumi.String("string"),
		},
	},
	SubscriptionGroups: opentelekomcloud.DmsRocketmqMigrationTaskV2SubscriptionGroupArray{
		&opentelekomcloud.DmsRocketmqMigrationTaskV2SubscriptionGroupArgs{
			GroupName:                      pulumi.String("string"),
			ConsumeBroadcastEnable:         pulumi.Bool(false),
			ConsumeEnable:                  pulumi.Bool(false),
			ConsumeFromMinEnable:           pulumi.Bool(false),
			NotifyConsumerIdsChangedEnable: pulumi.Bool(false),
			RetryMaxTimes:                  pulumi.Float64(0),
			RetryQueueNums:                 pulumi.Float64(0),
			WhichBrokerWhenConsumeSlow:     pulumi.Float64(0),
		},
	},
	Timeouts: &opentelekomcloud.DmsRocketmqMigrationTaskV2TimeoutsArgs{
		Create: pulumi.String("string"),
	},
	TopicConfigs: opentelekomcloud.DmsRocketmqMigrationTaskV2TopicConfigArray{
		&opentelekomcloud.DmsRocketmqMigrationTaskV2TopicConfigArgs{
			TopicName:       pulumi.String("string"),
			Order:           pulumi.Bool(false),
			Perm:            pulumi.Float64(0),
			ReadQueueNums:   pulumi.Float64(0),
			TopicFilterType: pulumi.String("string"),
			TopicSysFlag:    pulumi.Float64(0),
			WriteQueueNums:  pulumi.Float64(0),
		},
	},
	Vhosts: opentelekomcloud.DmsRocketmqMigrationTaskV2VhostArray{
		&opentelekomcloud.DmsRocketmqMigrationTaskV2VhostArgs{
			Name: pulumi.String("string"),
		},
	},
})

    resource "opentelekomcloud_dms_rocketmq_migration_task_v2" "dmsRocketmqMigrationTaskV2Resource" {
  lifecycle {
    create_before_destroy = true
  }
  instance_id = "string"
  type        = "string"
  bindings {
    destination      = "string"
    destination_type = "string"
    routing_key      = "string"
    source           = "string"
    vhost            = "string"
  }
  dms_rocketmq_migration_task_v2_id = "string"
  exchanges {
    durable = false
    name    = "string"
    type    = "string"
    vhost   = "string"
  }
  name      = "string"
  overwrite = false
  queues {
    durable = false
    name    = "string"
    vhost   = "string"
  }
  subscription_groups {
    group_name                         = "string"
    consume_broadcast_enable           = false
    consume_enable                     = false
    consume_from_min_enable            = false
    notify_consumer_ids_changed_enable = false
    retry_max_times                    = 0
    retry_queue_nums                   = 0
    which_broker_when_consume_slow     = 0
  }
  timeouts = {
    create = "string"
  }
  topic_configs {
    topic_name        = "string"
    order             = false
    perm              = 0
    read_queue_nums   = 0
    topic_filter_type = "string"
    topic_sys_flag    = 0
    write_queue_nums  = 0
  }
  vhosts {
    name = "string"
  }
}

    var dmsRocketmqMigrationTaskV2Resource = new DmsRocketmqMigrationTaskV2("dmsRocketmqMigrationTaskV2Resource", DmsRocketmqMigrationTaskV2Args.builder()
    .instanceId("string")
    .type("string")
    .bindings(DmsRocketmqMigrationTaskV2BindingArgs.builder()
        .destination("string")
        .destinationType("string")
        .routingKey("string")
        .source("string")
        .vhost("string")
        .build())
    .dmsRocketmqMigrationTaskV2Id("string")
    .exchanges(DmsRocketmqMigrationTaskV2ExchangeArgs.builder()
        .durable(false)
        .name("string")
        .type("string")
        .vhost("string")
        .build())
    .name("string")
    .overwrite(false)
    .queues(DmsRocketmqMigrationTaskV2QueueArgs.builder()
        .durable(false)
        .name("string")
        .vhost("string")
        .build())
    .subscriptionGroups(DmsRocketmqMigrationTaskV2SubscriptionGroupArgs.builder()
        .groupName("string")
        .consumeBroadcastEnable(false)
        .consumeEnable(false)
        .consumeFromMinEnable(false)
        .notifyConsumerIdsChangedEnable(false)
        .retryMaxTimes(0.0)
        .retryQueueNums(0.0)
        .whichBrokerWhenConsumeSlow(0.0)
        .build())
    .timeouts(DmsRocketmqMigrationTaskV2TimeoutsArgs.builder()
        .create("string")
        .build())
    .topicConfigs(DmsRocketmqMigrationTaskV2TopicConfigArgs.builder()
        .topicName("string")
        .order(false)
        .perm(0.0)
        .readQueueNums(0.0)
        .topicFilterType("string")
        .topicSysFlag(0.0)
        .writeQueueNums(0.0)
        .build())
    .vhosts(DmsRocketmqMigrationTaskV2VhostArgs.builder()
        .name("string")
        .build())
    .build());

    dms_rocketmq_migration_task_v2_resource = opentelekomcloud.DmsRocketmqMigrationTaskV2("dmsRocketmqMigrationTaskV2Resource",
    instance_id="string",
    type="string",
    bindings=[{
        "destination": "string",
        "destination_type": "string",
        "routing_key": "string",
        "source": "string",
        "vhost": "string",
    }],
    dms_rocketmq_migration_task_v2_id="string",
    exchanges=[{
        "durable": False,
        "name": "string",
        "type": "string",
        "vhost": "string",
    }],
    name="string",
    overwrite=False,
    queues=[{
        "durable": False,
        "name": "string",
        "vhost": "string",
    }],
    subscription_groups=[{
        "group_name": "string",
        "consume_broadcast_enable": False,
        "consume_enable": False,
        "consume_from_min_enable": False,
        "notify_consumer_ids_changed_enable": False,
        "retry_max_times": float(0),
        "retry_queue_nums": float(0),
        "which_broker_when_consume_slow": float(0),
    }],
    timeouts={
        "create": "string",
    },
    topic_configs=[{
        "topic_name": "string",
        "order": False,
        "perm": float(0),
        "read_queue_nums": float(0),
        "topic_filter_type": "string",
        "topic_sys_flag": float(0),
        "write_queue_nums": float(0),
    }],
    vhosts=[{
        "name": "string",
    }])

    const dmsRocketmqMigrationTaskV2Resource = new opentelekomcloud.DmsRocketmqMigrationTaskV2("dmsRocketmqMigrationTaskV2Resource", {
    instanceId: "string",
    type: "string",
    bindings: [{
        destination: "string",
        destinationType: "string",
        routingKey: "string",
        source: "string",
        vhost: "string",
    }],
    dmsRocketmqMigrationTaskV2Id: "string",
    exchanges: [{
        durable: false,
        name: "string",
        type: "string",
        vhost: "string",
    }],
    name: "string",
    overwrite: false,
    queues: [{
        durable: false,
        name: "string",
        vhost: "string",
    }],
    subscriptionGroups: [{
        groupName: "string",
        consumeBroadcastEnable: false,
        consumeEnable: false,
        consumeFromMinEnable: false,
        notifyConsumerIdsChangedEnable: false,
        retryMaxTimes: 0,
        retryQueueNums: 0,
        whichBrokerWhenConsumeSlow: 0,
    }],
    timeouts: {
        create: "string",
    },
    topicConfigs: [{
        topicName: "string",
        order: false,
        perm: 0,
        readQueueNums: 0,
        topicFilterType: "string",
        topicSysFlag: 0,
        writeQueueNums: 0,
    }],
    vhosts: [{
        name: "string",
    }],
});

    type: opentelekomcloud:DmsRocketmqMigrationTaskV2
properties:
    bindings:
        - destination: string
          destinationType: string
          routingKey: string
          source: string
          vhost: string
    dmsRocketmqMigrationTaskV2Id: string
    exchanges:
        - durable: false
          name: string
          type: string
          vhost: string
    instanceId: string
    name: string
    overwrite: false
    queues:
        - durable: false
          name: string
          vhost: string
    subscriptionGroups:
        - consumeBroadcastEnable: false
          consumeEnable: false
          consumeFromMinEnable: false
          groupName: string
          notifyConsumerIdsChangedEnable: false
          retryMaxTimes: 0
          retryQueueNums: 0
          whichBrokerWhenConsumeSlow: 0
    timeouts:
        create: string
    topicConfigs:
        - order: false
          perm: 0
          readQueueNums: 0
          topicFilterType: string
          topicName: string
          topicSysFlag: 0
          writeQueueNums: 0
    type: string
    vhosts:
        - name: string

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

    InstanceId string
    Specifies the ID of the RocketMQ instance. Changing this creates a new resource.
    Type string
    Specifies the exchange type. Value options: topic, direct, fanout, headers.
    Bindings List<DmsRocketmqMigrationTaskV2Binding>

    Specifies the binding metadata. Mandatory for rabbitToRocket tasks. The bindings structure is documented below. Changing this creates a new resource.

    The topic_configs block supports:

    DmsRocketmqMigrationTaskV2Id string
    The resource ID in format <instance_id>/<task_id>.
    Exchanges List<DmsRocketmqMigrationTaskV2Exchange>
    Specifies the exchange metadata. Mandatory for rabbitToRocket tasks. The exchanges structure is documented below. Changing this creates a new resource.
    Name string
    Specifies the exchange name.
    Overwrite bool
    Specifies whether to overwrite configurations of the existing topics and consumer groups with the same name. If false, an error is reported when a topic or group already exists. Defaults to false. Changing this creates a new resource.
    Queues List<DmsRocketmqMigrationTaskV2Queue>
    Specifies the queue metadata. Mandatory for rabbitToRocket tasks. The queues structure is documented below. Changing this creates a new resource.
    SubscriptionGroups List<DmsRocketmqMigrationTaskV2SubscriptionGroup>
    Specifies the consumer group metadata. Mandatory for rocketmq tasks. The subscription_groups structure is documented below. Changing this creates a new resource.
    Timeouts DmsRocketmqMigrationTaskV2Timeouts
    TopicConfigs List<DmsRocketmqMigrationTaskV2TopicConfig>
    Specifies the topic metadata. Mandatory for rocketmq tasks. The topic_configs structure is documented below. Changing this creates a new resource.
    Vhosts List<DmsRocketmqMigrationTaskV2Vhost>
    Specifies the virtual host metadata. Mandatory for rabbitToRocket tasks. The vhosts structure is documented below. Changing this creates a new resource.
    InstanceId string
    Specifies the ID of the RocketMQ instance. Changing this creates a new resource.
    Type string
    Specifies the exchange type. Value options: topic, direct, fanout, headers.
    Bindings []DmsRocketmqMigrationTaskV2BindingArgs

    Specifies the binding metadata. Mandatory for rabbitToRocket tasks. The bindings structure is documented below. Changing this creates a new resource.

    The topic_configs block supports:

    DmsRocketmqMigrationTaskV2Id string
    The resource ID in format <instance_id>/<task_id>.
    Exchanges []DmsRocketmqMigrationTaskV2ExchangeArgs
    Specifies the exchange metadata. Mandatory for rabbitToRocket tasks. The exchanges structure is documented below. Changing this creates a new resource.
    Name string
    Specifies the exchange name.
    Overwrite bool
    Specifies whether to overwrite configurations of the existing topics and consumer groups with the same name. If false, an error is reported when a topic or group already exists. Defaults to false. Changing this creates a new resource.
    Queues []DmsRocketmqMigrationTaskV2QueueArgs
    Specifies the queue metadata. Mandatory for rabbitToRocket tasks. The queues structure is documented below. Changing this creates a new resource.
    SubscriptionGroups []DmsRocketmqMigrationTaskV2SubscriptionGroupArgs
    Specifies the consumer group metadata. Mandatory for rocketmq tasks. The subscription_groups structure is documented below. Changing this creates a new resource.
    Timeouts DmsRocketmqMigrationTaskV2TimeoutsArgs
    TopicConfigs []DmsRocketmqMigrationTaskV2TopicConfigArgs
    Specifies the topic metadata. Mandatory for rocketmq tasks. The topic_configs structure is documented below. Changing this creates a new resource.
    Vhosts []DmsRocketmqMigrationTaskV2VhostArgs
    Specifies the virtual host metadata. Mandatory for rabbitToRocket tasks. The vhosts structure is documented below. Changing this creates a new resource.
    instance_id string
    Specifies the ID of the RocketMQ instance. Changing this creates a new resource.
    type string
    Specifies the exchange type. Value options: topic, direct, fanout, headers.
    bindings list(object)

    Specifies the binding metadata. Mandatory for rabbitToRocket tasks. The bindings structure is documented below. Changing this creates a new resource.

    The topic_configs block supports:

    dms_rocketmq_migration_task_v2_id string
    The resource ID in format <instance_id>/<task_id>.
    exchanges list(object)
    Specifies the exchange metadata. Mandatory for rabbitToRocket tasks. The exchanges structure is documented below. Changing this creates a new resource.
    name string
    Specifies the exchange name.
    overwrite bool
    Specifies whether to overwrite configurations of the existing topics and consumer groups with the same name. If false, an error is reported when a topic or group already exists. Defaults to false. Changing this creates a new resource.
    queues list(object)
    Specifies the queue metadata. Mandatory for rabbitToRocket tasks. The queues structure is documented below. Changing this creates a new resource.
    subscription_groups list(object)
    Specifies the consumer group metadata. Mandatory for rocketmq tasks. The subscription_groups structure is documented below. Changing this creates a new resource.
    timeouts object
    topic_configs list(object)
    Specifies the topic metadata. Mandatory for rocketmq tasks. The topic_configs structure is documented below. Changing this creates a new resource.
    vhosts list(object)
    Specifies the virtual host metadata. Mandatory for rabbitToRocket tasks. The vhosts structure is documented below. Changing this creates a new resource.
    instanceId String
    Specifies the ID of the RocketMQ instance. Changing this creates a new resource.
    type String
    Specifies the exchange type. Value options: topic, direct, fanout, headers.
    bindings List<DmsRocketmqMigrationTaskV2Binding>

    Specifies the binding metadata. Mandatory for rabbitToRocket tasks. The bindings structure is documented below. Changing this creates a new resource.

    The topic_configs block supports:

    dmsRocketmqMigrationTaskV2Id String
    The resource ID in format <instance_id>/<task_id>.
    exchanges List<DmsRocketmqMigrationTaskV2Exchange>
    Specifies the exchange metadata. Mandatory for rabbitToRocket tasks. The exchanges structure is documented below. Changing this creates a new resource.
    name String
    Specifies the exchange name.
    overwrite Boolean
    Specifies whether to overwrite configurations of the existing topics and consumer groups with the same name. If false, an error is reported when a topic or group already exists. Defaults to false. Changing this creates a new resource.
    queues List<DmsRocketmqMigrationTaskV2Queue>
    Specifies the queue metadata. Mandatory for rabbitToRocket tasks. The queues structure is documented below. Changing this creates a new resource.
    subscriptionGroups List<DmsRocketmqMigrationTaskV2SubscriptionGroup>
    Specifies the consumer group metadata. Mandatory for rocketmq tasks. The subscription_groups structure is documented below. Changing this creates a new resource.
    timeouts DmsRocketmqMigrationTaskV2Timeouts
    topicConfigs List<DmsRocketmqMigrationTaskV2TopicConfig>
    Specifies the topic metadata. Mandatory for rocketmq tasks. The topic_configs structure is documented below. Changing this creates a new resource.
    vhosts List<DmsRocketmqMigrationTaskV2Vhost>
    Specifies the virtual host metadata. Mandatory for rabbitToRocket tasks. The vhosts structure is documented below. Changing this creates a new resource.
    instanceId string
    Specifies the ID of the RocketMQ instance. Changing this creates a new resource.
    type string
    Specifies the exchange type. Value options: topic, direct, fanout, headers.
    bindings DmsRocketmqMigrationTaskV2Binding[]

    Specifies the binding metadata. Mandatory for rabbitToRocket tasks. The bindings structure is documented below. Changing this creates a new resource.

    The topic_configs block supports:

    dmsRocketmqMigrationTaskV2Id string
    The resource ID in format <instance_id>/<task_id>.
    exchanges DmsRocketmqMigrationTaskV2Exchange[]
    Specifies the exchange metadata. Mandatory for rabbitToRocket tasks. The exchanges structure is documented below. Changing this creates a new resource.
    name string
    Specifies the exchange name.
    overwrite boolean
    Specifies whether to overwrite configurations of the existing topics and consumer groups with the same name. If false, an error is reported when a topic or group already exists. Defaults to false. Changing this creates a new resource.
    queues DmsRocketmqMigrationTaskV2Queue[]
    Specifies the queue metadata. Mandatory for rabbitToRocket tasks. The queues structure is documented below. Changing this creates a new resource.
    subscriptionGroups DmsRocketmqMigrationTaskV2SubscriptionGroup[]
    Specifies the consumer group metadata. Mandatory for rocketmq tasks. The subscription_groups structure is documented below. Changing this creates a new resource.
    timeouts DmsRocketmqMigrationTaskV2Timeouts
    topicConfigs DmsRocketmqMigrationTaskV2TopicConfig[]
    Specifies the topic metadata. Mandatory for rocketmq tasks. The topic_configs structure is documented below. Changing this creates a new resource.
    vhosts DmsRocketmqMigrationTaskV2Vhost[]
    Specifies the virtual host metadata. Mandatory for rabbitToRocket tasks. The vhosts structure is documented below. Changing this creates a new resource.
    instance_id str
    Specifies the ID of the RocketMQ instance. Changing this creates a new resource.
    type str
    Specifies the exchange type. Value options: topic, direct, fanout, headers.
    bindings Sequence[DmsRocketmqMigrationTaskV2BindingArgs]

    Specifies the binding metadata. Mandatory for rabbitToRocket tasks. The bindings structure is documented below. Changing this creates a new resource.

    The topic_configs block supports:

    dms_rocketmq_migration_task_v2_id str
    The resource ID in format <instance_id>/<task_id>.
    exchanges Sequence[DmsRocketmqMigrationTaskV2ExchangeArgs]
    Specifies the exchange metadata. Mandatory for rabbitToRocket tasks. The exchanges structure is documented below. Changing this creates a new resource.
    name str
    Specifies the exchange name.
    overwrite bool
    Specifies whether to overwrite configurations of the existing topics and consumer groups with the same name. If false, an error is reported when a topic or group already exists. Defaults to false. Changing this creates a new resource.
    queues Sequence[DmsRocketmqMigrationTaskV2QueueArgs]
    Specifies the queue metadata. Mandatory for rabbitToRocket tasks. The queues structure is documented below. Changing this creates a new resource.
    subscription_groups Sequence[DmsRocketmqMigrationTaskV2SubscriptionGroupArgs]
    Specifies the consumer group metadata. Mandatory for rocketmq tasks. The subscription_groups structure is documented below. Changing this creates a new resource.
    timeouts DmsRocketmqMigrationTaskV2TimeoutsArgs
    topic_configs Sequence[DmsRocketmqMigrationTaskV2TopicConfigArgs]
    Specifies the topic metadata. Mandatory for rocketmq tasks. The topic_configs structure is documented below. Changing this creates a new resource.
    vhosts Sequence[DmsRocketmqMigrationTaskV2VhostArgs]
    Specifies the virtual host metadata. Mandatory for rabbitToRocket tasks. The vhosts structure is documented below. Changing this creates a new resource.
    instanceId String
    Specifies the ID of the RocketMQ instance. Changing this creates a new resource.
    type String
    Specifies the exchange type. Value options: topic, direct, fanout, headers.
    bindings List<Property Map>

    Specifies the binding metadata. Mandatory for rabbitToRocket tasks. The bindings structure is documented below. Changing this creates a new resource.

    The topic_configs block supports:

    dmsRocketmqMigrationTaskV2Id String
    The resource ID in format <instance_id>/<task_id>.
    exchanges List<Property Map>
    Specifies the exchange metadata. Mandatory for rabbitToRocket tasks. The exchanges structure is documented below. Changing this creates a new resource.
    name String
    Specifies the exchange name.
    overwrite Boolean
    Specifies whether to overwrite configurations of the existing topics and consumer groups with the same name. If false, an error is reported when a topic or group already exists. Defaults to false. Changing this creates a new resource.
    queues List<Property Map>
    Specifies the queue metadata. Mandatory for rabbitToRocket tasks. The queues structure is documented below. Changing this creates a new resource.
    subscriptionGroups List<Property Map>
    Specifies the consumer group metadata. Mandatory for rocketmq tasks. The subscription_groups structure is documented below. Changing this creates a new resource.
    timeouts Property Map
    topicConfigs List<Property Map>
    Specifies the topic metadata. Mandatory for rocketmq tasks. The topic_configs structure is documented below. Changing this creates a new resource.
    vhosts List<Property Map>
    Specifies the virtual host metadata. Mandatory for rabbitToRocket tasks. The vhosts structure is documented below. Changing this creates a new resource.

    Outputs

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

    Id string
    The provider-assigned unique ID for this managed resource.
    StartDate string
    Indicates the start time of the migration task.
    Status string
    Indicates the status of the migration task. Values: creating, starting, failed, finished.
    Id string
    The provider-assigned unique ID for this managed resource.
    StartDate string
    Indicates the start time of the migration task.
    Status string
    Indicates the status of the migration task. Values: creating, starting, failed, finished.
    id string
    The provider-assigned unique ID for this managed resource.
    start_date string
    Indicates the start time of the migration task.
    status string
    Indicates the status of the migration task. Values: creating, starting, failed, finished.
    id String
    The provider-assigned unique ID for this managed resource.
    startDate String
    Indicates the start time of the migration task.
    status String
    Indicates the status of the migration task. Values: creating, starting, failed, finished.
    id string
    The provider-assigned unique ID for this managed resource.
    startDate string
    Indicates the start time of the migration task.
    status string
    Indicates the status of the migration task. Values: creating, starting, failed, finished.
    id str
    The provider-assigned unique ID for this managed resource.
    start_date str
    Indicates the start time of the migration task.
    status str
    Indicates the status of the migration task. Values: creating, starting, failed, finished.
    id String
    The provider-assigned unique ID for this managed resource.
    startDate String
    Indicates the start time of the migration task.
    status String
    Indicates the status of the migration task. Values: creating, starting, failed, finished.

    Look up Existing DmsRocketmqMigrationTaskV2 Resource

    Get an existing DmsRocketmqMigrationTaskV2 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?: DmsRocketmqMigrationTaskV2State, opts?: CustomResourceOptions): DmsRocketmqMigrationTaskV2
    @staticmethod
def get(resource_name: str,
        id: str,
        opts: Optional[ResourceOptions] = None,
        bindings: Optional[Sequence[DmsRocketmqMigrationTaskV2BindingArgs]] = None,
        dms_rocketmq_migration_task_v2_id: Optional[str] = None,
        exchanges: Optional[Sequence[DmsRocketmqMigrationTaskV2ExchangeArgs]] = None,
        instance_id: Optional[str] = None,
        name: Optional[str] = None,
        overwrite: Optional[bool] = None,
        queues: Optional[Sequence[DmsRocketmqMigrationTaskV2QueueArgs]] = None,
        start_date: Optional[str] = None,
        status: Optional[str] = None,
        subscription_groups: Optional[Sequence[DmsRocketmqMigrationTaskV2SubscriptionGroupArgs]] = None,
        timeouts: Optional[DmsRocketmqMigrationTaskV2TimeoutsArgs] = None,
        topic_configs: Optional[Sequence[DmsRocketmqMigrationTaskV2TopicConfigArgs]] = None,
        type: Optional[str] = None,
        vhosts: Optional[Sequence[DmsRocketmqMigrationTaskV2VhostArgs]] = None) -> DmsRocketmqMigrationTaskV2
    func GetDmsRocketmqMigrationTaskV2(ctx *Context, name string, id IDInput, state *DmsRocketmqMigrationTaskV2State, opts ...ResourceOption) (*DmsRocketmqMigrationTaskV2, error)
    public static DmsRocketmqMigrationTaskV2 Get(string name, Input<string> id, DmsRocketmqMigrationTaskV2State? state, CustomResourceOptions? opts = null)
    public static DmsRocketmqMigrationTaskV2 get(String name, Output<String> id, DmsRocketmqMigrationTaskV2State state, CustomResourceOptions options)
    resources:  _:    type: opentelekomcloud:DmsRocketmqMigrationTaskV2    get:      id: ${id}
    import {
  to = opentelekomcloud_dms_rocketmq_migration_task_v2.example
  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:
    Bindings List<DmsRocketmqMigrationTaskV2Binding>

    Specifies the binding metadata. Mandatory for rabbitToRocket tasks. The bindings structure is documented below. Changing this creates a new resource.

    The topic_configs block supports:

    DmsRocketmqMigrationTaskV2Id string
    The resource ID in format <instance_id>/<task_id>.
    Exchanges List<DmsRocketmqMigrationTaskV2Exchange>
    Specifies the exchange metadata. Mandatory for rabbitToRocket tasks. The exchanges structure is documented below. Changing this creates a new resource.
    InstanceId string
    Specifies the ID of the RocketMQ instance. Changing this creates a new resource.
    Name string
    Specifies the exchange name.
    Overwrite bool
    Specifies whether to overwrite configurations of the existing topics and consumer groups with the same name. If false, an error is reported when a topic or group already exists. Defaults to false. Changing this creates a new resource.
    Queues List<DmsRocketmqMigrationTaskV2Queue>
    Specifies the queue metadata. Mandatory for rabbitToRocket tasks. The queues structure is documented below. Changing this creates a new resource.
    StartDate string
    Indicates the start time of the migration task.
    Status string
    Indicates the status of the migration task. Values: creating, starting, failed, finished.
    SubscriptionGroups List<DmsRocketmqMigrationTaskV2SubscriptionGroup>
    Specifies the consumer group metadata. Mandatory for rocketmq tasks. The subscription_groups structure is documented below. Changing this creates a new resource.
    Timeouts DmsRocketmqMigrationTaskV2Timeouts
    TopicConfigs List<DmsRocketmqMigrationTaskV2TopicConfig>
    Specifies the topic metadata. Mandatory for rocketmq tasks. The topic_configs structure is documented below. Changing this creates a new resource.
    Type string
    Specifies the exchange type. Value options: topic, direct, fanout, headers.
    Vhosts List<DmsRocketmqMigrationTaskV2Vhost>
    Specifies the virtual host metadata. Mandatory for rabbitToRocket tasks. The vhosts structure is documented below. Changing this creates a new resource.
    Bindings []DmsRocketmqMigrationTaskV2BindingArgs

    Specifies the binding metadata. Mandatory for rabbitToRocket tasks. The bindings structure is documented below. Changing this creates a new resource.

    The topic_configs block supports:

    DmsRocketmqMigrationTaskV2Id string
    The resource ID in format <instance_id>/<task_id>.
    Exchanges []DmsRocketmqMigrationTaskV2ExchangeArgs
    Specifies the exchange metadata. Mandatory for rabbitToRocket tasks. The exchanges structure is documented below. Changing this creates a new resource.
    InstanceId string
    Specifies the ID of the RocketMQ instance. Changing this creates a new resource.
    Name string
    Specifies the exchange name.
    Overwrite bool
    Specifies whether to overwrite configurations of the existing topics and consumer groups with the same name. If false, an error is reported when a topic or group already exists. Defaults to false. Changing this creates a new resource.
    Queues []DmsRocketmqMigrationTaskV2QueueArgs
    Specifies the queue metadata. Mandatory for rabbitToRocket tasks. The queues structure is documented below. Changing this creates a new resource.
    StartDate string
    Indicates the start time of the migration task.
    Status string
    Indicates the status of the migration task. Values: creating, starting, failed, finished.
    SubscriptionGroups []DmsRocketmqMigrationTaskV2SubscriptionGroupArgs
    Specifies the consumer group metadata. Mandatory for rocketmq tasks. The subscription_groups structure is documented below. Changing this creates a new resource.
    Timeouts DmsRocketmqMigrationTaskV2TimeoutsArgs
    TopicConfigs []DmsRocketmqMigrationTaskV2TopicConfigArgs
    Specifies the topic metadata. Mandatory for rocketmq tasks. The topic_configs structure is documented below. Changing this creates a new resource.
    Type string
    Specifies the exchange type. Value options: topic, direct, fanout, headers.
    Vhosts []DmsRocketmqMigrationTaskV2VhostArgs
    Specifies the virtual host metadata. Mandatory for rabbitToRocket tasks. The vhosts structure is documented below. Changing this creates a new resource.
    bindings list(object)

    Specifies the binding metadata. Mandatory for rabbitToRocket tasks. The bindings structure is documented below. Changing this creates a new resource.

    The topic_configs block supports:

    dms_rocketmq_migration_task_v2_id string
    The resource ID in format <instance_id>/<task_id>.
    exchanges list(object)
    Specifies the exchange metadata. Mandatory for rabbitToRocket tasks. The exchanges structure is documented below. Changing this creates a new resource.
    instance_id string
    Specifies the ID of the RocketMQ instance. Changing this creates a new resource.
    name string
    Specifies the exchange name.
    overwrite bool
    Specifies whether to overwrite configurations of the existing topics and consumer groups with the same name. If false, an error is reported when a topic or group already exists. Defaults to false. Changing this creates a new resource.
    queues list(object)
    Specifies the queue metadata. Mandatory for rabbitToRocket tasks. The queues structure is documented below. Changing this creates a new resource.
    start_date string
    Indicates the start time of the migration task.
    status string
    Indicates the status of the migration task. Values: creating, starting, failed, finished.
    subscription_groups list(object)
    Specifies the consumer group metadata. Mandatory for rocketmq tasks. The subscription_groups structure is documented below. Changing this creates a new resource.
    timeouts object
    topic_configs list(object)
    Specifies the topic metadata. Mandatory for rocketmq tasks. The topic_configs structure is documented below. Changing this creates a new resource.
    type string
    Specifies the exchange type. Value options: topic, direct, fanout, headers.
    vhosts list(object)
    Specifies the virtual host metadata. Mandatory for rabbitToRocket tasks. The vhosts structure is documented below. Changing this creates a new resource.
    bindings List<DmsRocketmqMigrationTaskV2Binding>

    Specifies the binding metadata. Mandatory for rabbitToRocket tasks. The bindings structure is documented below. Changing this creates a new resource.

    The topic_configs block supports:

    dmsRocketmqMigrationTaskV2Id String
    The resource ID in format <instance_id>/<task_id>.
    exchanges List<DmsRocketmqMigrationTaskV2Exchange>
    Specifies the exchange metadata. Mandatory for rabbitToRocket tasks. The exchanges structure is documented below. Changing this creates a new resource.
    instanceId String
    Specifies the ID of the RocketMQ instance. Changing this creates a new resource.
    name String
    Specifies the exchange name.
    overwrite Boolean
    Specifies whether to overwrite configurations of the existing topics and consumer groups with the same name. If false, an error is reported when a topic or group already exists. Defaults to false. Changing this creates a new resource.
    queues List<DmsRocketmqMigrationTaskV2Queue>
    Specifies the queue metadata. Mandatory for rabbitToRocket tasks. The queues structure is documented below. Changing this creates a new resource.
    startDate String
    Indicates the start time of the migration task.
    status String
    Indicates the status of the migration task. Values: creating, starting, failed, finished.
    subscriptionGroups List<DmsRocketmqMigrationTaskV2SubscriptionGroup>
    Specifies the consumer group metadata. Mandatory for rocketmq tasks. The subscription_groups structure is documented below. Changing this creates a new resource.
    timeouts DmsRocketmqMigrationTaskV2Timeouts
    topicConfigs List<DmsRocketmqMigrationTaskV2TopicConfig>
    Specifies the topic metadata. Mandatory for rocketmq tasks. The topic_configs structure is documented below. Changing this creates a new resource.
    type String
    Specifies the exchange type. Value options: topic, direct, fanout, headers.
    vhosts List<DmsRocketmqMigrationTaskV2Vhost>
    Specifies the virtual host metadata. Mandatory for rabbitToRocket tasks. The vhosts structure is documented below. Changing this creates a new resource.
    bindings DmsRocketmqMigrationTaskV2Binding[]

    Specifies the binding metadata. Mandatory for rabbitToRocket tasks. The bindings structure is documented below. Changing this creates a new resource.

    The topic_configs block supports:

    dmsRocketmqMigrationTaskV2Id string
    The resource ID in format <instance_id>/<task_id>.
    exchanges DmsRocketmqMigrationTaskV2Exchange[]
    Specifies the exchange metadata. Mandatory for rabbitToRocket tasks. The exchanges structure is documented below. Changing this creates a new resource.
    instanceId string
    Specifies the ID of the RocketMQ instance. Changing this creates a new resource.
    name string
    Specifies the exchange name.
    overwrite boolean
    Specifies whether to overwrite configurations of the existing topics and consumer groups with the same name. If false, an error is reported when a topic or group already exists. Defaults to false. Changing this creates a new resource.
    queues DmsRocketmqMigrationTaskV2Queue[]
    Specifies the queue metadata. Mandatory for rabbitToRocket tasks. The queues structure is documented below. Changing this creates a new resource.
    startDate string
    Indicates the start time of the migration task.
    status string
    Indicates the status of the migration task. Values: creating, starting, failed, finished.
    subscriptionGroups DmsRocketmqMigrationTaskV2SubscriptionGroup[]
    Specifies the consumer group metadata. Mandatory for rocketmq tasks. The subscription_groups structure is documented below. Changing this creates a new resource.
    timeouts DmsRocketmqMigrationTaskV2Timeouts
    topicConfigs DmsRocketmqMigrationTaskV2TopicConfig[]
    Specifies the topic metadata. Mandatory for rocketmq tasks. The topic_configs structure is documented below. Changing this creates a new resource.
    type string
    Specifies the exchange type. Value options: topic, direct, fanout, headers.
    vhosts DmsRocketmqMigrationTaskV2Vhost[]
    Specifies the virtual host metadata. Mandatory for rabbitToRocket tasks. The vhosts structure is documented below. Changing this creates a new resource.
    bindings Sequence[DmsRocketmqMigrationTaskV2BindingArgs]

    Specifies the binding metadata. Mandatory for rabbitToRocket tasks. The bindings structure is documented below. Changing this creates a new resource.

    The topic_configs block supports:

    dms_rocketmq_migration_task_v2_id str
    The resource ID in format <instance_id>/<task_id>.
    exchanges Sequence[DmsRocketmqMigrationTaskV2ExchangeArgs]
    Specifies the exchange metadata. Mandatory for rabbitToRocket tasks. The exchanges structure is documented below. Changing this creates a new resource.
    instance_id str
    Specifies the ID of the RocketMQ instance. Changing this creates a new resource.
    name str
    Specifies the exchange name.
    overwrite bool
    Specifies whether to overwrite configurations of the existing topics and consumer groups with the same name. If false, an error is reported when a topic or group already exists. Defaults to false. Changing this creates a new resource.
    queues Sequence[DmsRocketmqMigrationTaskV2QueueArgs]
    Specifies the queue metadata. Mandatory for rabbitToRocket tasks. The queues structure is documented below. Changing this creates a new resource.
    start_date str
    Indicates the start time of the migration task.
    status str
    Indicates the status of the migration task. Values: creating, starting, failed, finished.
    subscription_groups Sequence[DmsRocketmqMigrationTaskV2SubscriptionGroupArgs]
    Specifies the consumer group metadata. Mandatory for rocketmq tasks. The subscription_groups structure is documented below. Changing this creates a new resource.
    timeouts DmsRocketmqMigrationTaskV2TimeoutsArgs
    topic_configs Sequence[DmsRocketmqMigrationTaskV2TopicConfigArgs]
    Specifies the topic metadata. Mandatory for rocketmq tasks. The topic_configs structure is documented below. Changing this creates a new resource.
    type str
    Specifies the exchange type. Value options: topic, direct, fanout, headers.
    vhosts Sequence[DmsRocketmqMigrationTaskV2VhostArgs]
    Specifies the virtual host metadata. Mandatory for rabbitToRocket tasks. The vhosts structure is documented below. Changing this creates a new resource.
    bindings List<Property Map>

    Specifies the binding metadata. Mandatory for rabbitToRocket tasks. The bindings structure is documented below. Changing this creates a new resource.

    The topic_configs block supports:

    dmsRocketmqMigrationTaskV2Id String
    The resource ID in format <instance_id>/<task_id>.
    exchanges List<Property Map>
    Specifies the exchange metadata. Mandatory for rabbitToRocket tasks. The exchanges structure is documented below. Changing this creates a new resource.
    instanceId String
    Specifies the ID of the RocketMQ instance. Changing this creates a new resource.
    name String
    Specifies the exchange name.
    overwrite Boolean
    Specifies whether to overwrite configurations of the existing topics and consumer groups with the same name. If false, an error is reported when a topic or group already exists. Defaults to false. Changing this creates a new resource.
    queues List<Property Map>
    Specifies the queue metadata. Mandatory for rabbitToRocket tasks. The queues structure is documented below. Changing this creates a new resource.
    startDate String
    Indicates the start time of the migration task.
    status String
    Indicates the status of the migration task. Values: creating, starting, failed, finished.
    subscriptionGroups List<Property Map>
    Specifies the consumer group metadata. Mandatory for rocketmq tasks. The subscription_groups structure is documented below. Changing this creates a new resource.
    timeouts Property Map
    topicConfigs List<Property Map>
    Specifies the topic metadata. Mandatory for rocketmq tasks. The topic_configs structure is documented below. Changing this creates a new resource.
    type String
    Specifies the exchange type. Value options: topic, direct, fanout, headers.
    vhosts List<Property Map>
    Specifies the virtual host metadata. Mandatory for rabbitToRocket tasks. The vhosts structure is documented below. Changing this creates a new resource.

    Supporting Types

    DmsRocketmqMigrationTaskV2Binding, DmsRocketmqMigrationTaskV2BindingArgs

    Destination string
    Specifies the message target.
    DestinationType string
    Specifies the target type. Value options: exchange, queue.
    RoutingKey string
    Specifies the routing key.
    Source string
    Specifies the message source.
    Vhost string
    Specifies the virtual host name.
    Destination string
    Specifies the message target.
    DestinationType string
    Specifies the target type. Value options: exchange, queue.
    RoutingKey string
    Specifies the routing key.
    Source string
    Specifies the message source.
    Vhost string
    Specifies the virtual host name.
    destination string
    Specifies the message target.
    destination_type string
    Specifies the target type. Value options: exchange, queue.
    routing_key string
    Specifies the routing key.
    source string
    Specifies the message source.
    vhost string
    Specifies the virtual host name.
    destination String
    Specifies the message target.
    destinationType String
    Specifies the target type. Value options: exchange, queue.
    routingKey String
    Specifies the routing key.
    source String
    Specifies the message source.
    vhost String
    Specifies the virtual host name.
    destination string
    Specifies the message target.
    destinationType string
    Specifies the target type. Value options: exchange, queue.
    routingKey string
    Specifies the routing key.
    source string
    Specifies the message source.
    vhost string
    Specifies the virtual host name.
    destination str
    Specifies the message target.
    destination_type str
    Specifies the target type. Value options: exchange, queue.
    routing_key str
    Specifies the routing key.
    source str
    Specifies the message source.
    vhost str
    Specifies the virtual host name.
    destination String
    Specifies the message target.
    destinationType String
    Specifies the target type. Value options: exchange, queue.
    routingKey String
    Specifies the routing key.
    source String
    Specifies the message source.
    vhost String
    Specifies the virtual host name.

    DmsRocketmqMigrationTaskV2Exchange, DmsRocketmqMigrationTaskV2ExchangeArgs

    Durable bool

    Specifies whether to enable data persistence. Defaults to false.

    The bindings block supports:

    Name string
    Specifies the exchange name.
    Type string
    Specifies the exchange type. Value options: topic, direct, fanout, headers.
    Vhost string
    Specifies the virtual host name.
    Durable bool

    Specifies whether to enable data persistence. Defaults to false.

    The bindings block supports:

    Name string
    Specifies the exchange name.
    Type string
    Specifies the exchange type. Value options: topic, direct, fanout, headers.
    Vhost string
    Specifies the virtual host name.
    durable bool

    Specifies whether to enable data persistence. Defaults to false.

    The bindings block supports:

    name string
    Specifies the exchange name.
    type string
    Specifies the exchange type. Value options: topic, direct, fanout, headers.
    vhost string
    Specifies the virtual host name.
    durable Boolean

    Specifies whether to enable data persistence. Defaults to false.

    The bindings block supports:

    name String
    Specifies the exchange name.
    type String
    Specifies the exchange type. Value options: topic, direct, fanout, headers.
    vhost String
    Specifies the virtual host name.
    durable boolean

    Specifies whether to enable data persistence. Defaults to false.

    The bindings block supports:

    name string
    Specifies the exchange name.
    type string
    Specifies the exchange type. Value options: topic, direct, fanout, headers.
    vhost string
    Specifies the virtual host name.
    durable bool

    Specifies whether to enable data persistence. Defaults to false.

    The bindings block supports:

    name str
    Specifies the exchange name.
    type str
    Specifies the exchange type. Value options: topic, direct, fanout, headers.
    vhost str
    Specifies the virtual host name.
    durable Boolean

    Specifies whether to enable data persistence. Defaults to false.

    The bindings block supports:

    name String
    Specifies the exchange name.
    type String
    Specifies the exchange type. Value options: topic, direct, fanout, headers.
    vhost String
    Specifies the virtual host name.

    DmsRocketmqMigrationTaskV2Queue, DmsRocketmqMigrationTaskV2QueueArgs

    Durable bool

    Specifies whether to enable data persistence. Defaults to false.

    The bindings block supports:

    Name string
    Specifies the exchange name.
    Vhost string
    Specifies the virtual host name.
    Durable bool

    Specifies whether to enable data persistence. Defaults to false.

    The bindings block supports:

    Name string
    Specifies the exchange name.
    Vhost string
    Specifies the virtual host name.
    durable bool

    Specifies whether to enable data persistence. Defaults to false.

    The bindings block supports:

    name string
    Specifies the exchange name.
    vhost string
    Specifies the virtual host name.
    durable Boolean

    Specifies whether to enable data persistence. Defaults to false.

    The bindings block supports:

    name String
    Specifies the exchange name.
    vhost String
    Specifies the virtual host name.
    durable boolean

    Specifies whether to enable data persistence. Defaults to false.

    The bindings block supports:

    name string
    Specifies the exchange name.
    vhost string
    Specifies the virtual host name.
    durable bool

    Specifies whether to enable data persistence. Defaults to false.

    The bindings block supports:

    name str
    Specifies the exchange name.
    vhost str
    Specifies the virtual host name.
    durable Boolean

    Specifies whether to enable data persistence. Defaults to false.

    The bindings block supports:

    name String
    Specifies the exchange name.
    vhost String
    Specifies the virtual host name.

    DmsRocketmqMigrationTaskV2SubscriptionGroup, DmsRocketmqMigrationTaskV2SubscriptionGroupArgs

    GroupName string
    Specifies the consumer group name.
    ConsumeBroadcastEnable bool
    Specifies whether to allow broadcast. Defaults to false.
    ConsumeEnable bool
    Specifies whether to enable consumption. Defaults to true.
    ConsumeFromMinEnable bool
    Specifies whether to enable consumption from the earliest offset. Defaults to true.
    NotifyConsumerIdsChangedEnable bool
    Specifies whether to notify consumer ID changes. Defaults to true.
    RetryMaxTimes double
    Specifies the maximum number of consumption retries. Defaults to 16.
    RetryQueueNums double
    Specifies the number of retry queues. Defaults to 1.
    WhichBrokerWhenConsumeSlow double

    Specifies the ID of the broker selected for slow consumption. Defaults to 1.

    The vhosts block supports:

    GroupName string
    Specifies the consumer group name.
    ConsumeBroadcastEnable bool
    Specifies whether to allow broadcast. Defaults to false.
    ConsumeEnable bool
    Specifies whether to enable consumption. Defaults to true.
    ConsumeFromMinEnable bool
    Specifies whether to enable consumption from the earliest offset. Defaults to true.
    NotifyConsumerIdsChangedEnable bool
    Specifies whether to notify consumer ID changes. Defaults to true.
    RetryMaxTimes float64
    Specifies the maximum number of consumption retries. Defaults to 16.
    RetryQueueNums float64
    Specifies the number of retry queues. Defaults to 1.
    WhichBrokerWhenConsumeSlow float64

    Specifies the ID of the broker selected for slow consumption. Defaults to 1.

    The vhosts block supports:

    group_name string
    Specifies the consumer group name.
    consume_broadcast_enable bool
    Specifies whether to allow broadcast. Defaults to false.
    consume_enable bool
    Specifies whether to enable consumption. Defaults to true.
    consume_from_min_enable bool
    Specifies whether to enable consumption from the earliest offset. Defaults to true.
    notify_consumer_ids_changed_enable bool
    Specifies whether to notify consumer ID changes. Defaults to true.
    retry_max_times number
    Specifies the maximum number of consumption retries. Defaults to 16.
    retry_queue_nums number
    Specifies the number of retry queues. Defaults to 1.
    which_broker_when_consume_slow number

    Specifies the ID of the broker selected for slow consumption. Defaults to 1.

    The vhosts block supports:

    groupName String
    Specifies the consumer group name.
    consumeBroadcastEnable Boolean
    Specifies whether to allow broadcast. Defaults to false.
    consumeEnable Boolean
    Specifies whether to enable consumption. Defaults to true.
    consumeFromMinEnable Boolean
    Specifies whether to enable consumption from the earliest offset. Defaults to true.
    notifyConsumerIdsChangedEnable Boolean
    Specifies whether to notify consumer ID changes. Defaults to true.
    retryMaxTimes Double
    Specifies the maximum number of consumption retries. Defaults to 16.
    retryQueueNums Double
    Specifies the number of retry queues. Defaults to 1.
    whichBrokerWhenConsumeSlow Double

    Specifies the ID of the broker selected for slow consumption. Defaults to 1.

    The vhosts block supports:

    groupName string
    Specifies the consumer group name.
    consumeBroadcastEnable boolean
    Specifies whether to allow broadcast. Defaults to false.
    consumeEnable boolean
    Specifies whether to enable consumption. Defaults to true.
    consumeFromMinEnable boolean
    Specifies whether to enable consumption from the earliest offset. Defaults to true.
    notifyConsumerIdsChangedEnable boolean
    Specifies whether to notify consumer ID changes. Defaults to true.
    retryMaxTimes number
    Specifies the maximum number of consumption retries. Defaults to 16.
    retryQueueNums number
    Specifies the number of retry queues. Defaults to 1.
    whichBrokerWhenConsumeSlow number

    Specifies the ID of the broker selected for slow consumption. Defaults to 1.

    The vhosts block supports:

    group_name str
    Specifies the consumer group name.
    consume_broadcast_enable bool
    Specifies whether to allow broadcast. Defaults to false.
    consume_enable bool
    Specifies whether to enable consumption. Defaults to true.
    consume_from_min_enable bool
    Specifies whether to enable consumption from the earliest offset. Defaults to true.
    notify_consumer_ids_changed_enable bool
    Specifies whether to notify consumer ID changes. Defaults to true.
    retry_max_times float
    Specifies the maximum number of consumption retries. Defaults to 16.
    retry_queue_nums float
    Specifies the number of retry queues. Defaults to 1.
    which_broker_when_consume_slow float

    Specifies the ID of the broker selected for slow consumption. Defaults to 1.

    The vhosts block supports:

    groupName String
    Specifies the consumer group name.
    consumeBroadcastEnable Boolean
    Specifies whether to allow broadcast. Defaults to false.
    consumeEnable Boolean
    Specifies whether to enable consumption. Defaults to true.
    consumeFromMinEnable Boolean
    Specifies whether to enable consumption from the earliest offset. Defaults to true.
    notifyConsumerIdsChangedEnable Boolean
    Specifies whether to notify consumer ID changes. Defaults to true.
    retryMaxTimes Number
    Specifies the maximum number of consumption retries. Defaults to 16.
    retryQueueNums Number
    Specifies the number of retry queues. Defaults to 1.
    whichBrokerWhenConsumeSlow Number

    Specifies the ID of the broker selected for slow consumption. Defaults to 1.

    The vhosts block supports:

    DmsRocketmqMigrationTaskV2Timeouts, DmsRocketmqMigrationTaskV2TimeoutsArgs

    Create string
    Create string
    create string
    create String
    create string
    create str
    create String

    DmsRocketmqMigrationTaskV2TopicConfig, DmsRocketmqMigrationTaskV2TopicConfigArgs

    TopicName string
    Specifies the topic name.
    Order bool
    Specifies whether messages are ordered. Defaults to false.
    Perm double
    Specifies the topic permissions. Defaults to 6.
    ReadQueueNums double
    Specifies the number of read queues. Defaults to 16.
    TopicFilterType string
    Specifies the topic filtering type. Value options: SINGLE_TAG, MULTI_TAG.
    TopicSysFlag double

    Specifies the topic system flag. Defaults to 0.

    The subscription_groups block supports:

    WriteQueueNums double
    Specifies the number of write queues. Defaults to 16.
    TopicName string
    Specifies the topic name.
    Order bool
    Specifies whether messages are ordered. Defaults to false.
    Perm float64
    Specifies the topic permissions. Defaults to 6.
    ReadQueueNums float64
    Specifies the number of read queues. Defaults to 16.
    TopicFilterType string
    Specifies the topic filtering type. Value options: SINGLE_TAG, MULTI_TAG.
    TopicSysFlag float64

    Specifies the topic system flag. Defaults to 0.

    The subscription_groups block supports:

    WriteQueueNums float64
    Specifies the number of write queues. Defaults to 16.
    topic_name string
    Specifies the topic name.
    order bool
    Specifies whether messages are ordered. Defaults to false.
    perm number
    Specifies the topic permissions. Defaults to 6.
    read_queue_nums number
    Specifies the number of read queues. Defaults to 16.
    topic_filter_type string
    Specifies the topic filtering type. Value options: SINGLE_TAG, MULTI_TAG.
    topic_sys_flag number

    Specifies the topic system flag. Defaults to 0.

    The subscription_groups block supports:

    write_queue_nums number
    Specifies the number of write queues. Defaults to 16.
    topicName String
    Specifies the topic name.
    order Boolean
    Specifies whether messages are ordered. Defaults to false.
    perm Double
    Specifies the topic permissions. Defaults to 6.
    readQueueNums Double
    Specifies the number of read queues. Defaults to 16.
    topicFilterType String
    Specifies the topic filtering type. Value options: SINGLE_TAG, MULTI_TAG.
    topicSysFlag Double

    Specifies the topic system flag. Defaults to 0.

    The subscription_groups block supports:

    writeQueueNums Double
    Specifies the number of write queues. Defaults to 16.
    topicName string
    Specifies the topic name.
    order boolean
    Specifies whether messages are ordered. Defaults to false.
    perm number
    Specifies the topic permissions. Defaults to 6.
    readQueueNums number
    Specifies the number of read queues. Defaults to 16.
    topicFilterType string
    Specifies the topic filtering type. Value options: SINGLE_TAG, MULTI_TAG.
    topicSysFlag number

    Specifies the topic system flag. Defaults to 0.

    The subscription_groups block supports:

    writeQueueNums number
    Specifies the number of write queues. Defaults to 16.
    topic_name str
    Specifies the topic name.
    order bool
    Specifies whether messages are ordered. Defaults to false.
    perm float
    Specifies the topic permissions. Defaults to 6.
    read_queue_nums float
    Specifies the number of read queues. Defaults to 16.
    topic_filter_type str
    Specifies the topic filtering type. Value options: SINGLE_TAG, MULTI_TAG.
    topic_sys_flag float

    Specifies the topic system flag. Defaults to 0.

    The subscription_groups block supports:

    write_queue_nums float
    Specifies the number of write queues. Defaults to 16.
    topicName String
    Specifies the topic name.
    order Boolean
    Specifies whether messages are ordered. Defaults to false.
    perm Number
    Specifies the topic permissions. Defaults to 6.
    readQueueNums Number
    Specifies the number of read queues. Defaults to 16.
    topicFilterType String
    Specifies the topic filtering type. Value options: SINGLE_TAG, MULTI_TAG.
    topicSysFlag Number

    Specifies the topic system flag. Defaults to 0.

    The subscription_groups block supports:

    writeQueueNums Number
    Specifies the number of write queues. Defaults to 16.

    DmsRocketmqMigrationTaskV2Vhost, DmsRocketmqMigrationTaskV2VhostArgs

    Name string
    Specifies the exchange name.
    Name string
    Specifies the exchange name.
    name string
    Specifies the exchange name.
    name String
    Specifies the exchange name.
    name string
    Specifies the exchange name.
    name str
    Specifies the exchange name.
    name String
    Specifies the exchange name.

    Import

    DMS RocketMQ migration task can be imported using the instance ID and task ID separated by a slash, e.g.

    $ pulumi import opentelekomcloud:index/dmsRocketmqMigrationTaskV2:DmsRocketmqMigrationTaskV2  opentelekomcloud_dms_rocketmq_migration_task_v2.test 8d3c7938-dc47-4937-a30f-c80de381c5e3/6cf4dcd3-8471-4139-8b5b-8a3a71f704c7

    Note that overwrite and the metadata blocks are not returned by the API, so they are missing in the imported state.

    You can ignore changes as below.

    hcl

    resource “opentelekomcloud_dms_rocketmq_migration_task_v2” “test” {

    lifecycle {

    ignore_changes = [

  overwrite,

  topic_configs,

  subscription_groups,

  vhosts,

  queues,

  exchanges,

  bindings,

]

    }

    }

    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
    Viewing docs for opentelekomcloud 1.37.11
    published on Friday, Oct 23, 2026 by opentelekomcloud
    Schema (JSON)
    opentelekomcloud/terraform-provider-opentelekomcloud

      Try Pulumi Cloud free.
      Your team will thank you.

      Start free trial