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

opentelekomcloud.DmsConsumerGroupV2

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 instance management you can get at documentation portal

    Manage DMS consumer group v2 resource within OpenTelekomCloud.

    Example Usage

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

const config = new pulumi.Config();
const instanceId = config.requireObject("instanceId");
const group1 = new opentelekomcloud.DmsConsumerGroupV2("group1", {
    instanceId: instanceId,
    groupName: "dms_consumer_group",
    description: "Sample consumer group",
});

    import pulumi
import pulumi_opentelekomcloud as opentelekomcloud

config = pulumi.Config()
instance_id = config.require_object("instanceId")
group1 = opentelekomcloud.DmsConsumerGroupV2("group1",
    instance_id=instance_id,
    group_name="dms_consumer_group",
    description="Sample consumer group")

    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.NewDmsConsumerGroupV2(ctx, "group1", &opentelekomcloud.DmsConsumerGroupV2Args{
			InstanceId:  pulumi.Any(instanceId),
			GroupName:   pulumi.String("dms_consumer_group"),
			Description: pulumi.String("Sample consumer group"),
		})
		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 group1 = new Opentelekomcloud.DmsConsumerGroupV2("group1", new()
    {
        InstanceId = instanceId,
        GroupName = "dms_consumer_group",
        Description = "Sample consumer group",
    });

});

    package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.opentelekomcloud.DmsConsumerGroupV2;
import com.pulumi.opentelekomcloud.DmsConsumerGroupV2Args;
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 group1 = new DmsConsumerGroupV2("group1", DmsConsumerGroupV2Args.builder()
            .instanceId(instanceId)
            .groupName("dms_consumer_group")
            .description("Sample consumer group")
            .build());

    }
}

    configuration:
  instanceId:
    type: dynamic
resources:
  group1:
    type: opentelekomcloud:DmsConsumerGroupV2
    properties:
      instanceId: ${instanceId}
      groupName: dms_consumer_group
      description: Sample consumer group

    Notes

    But due to some attributes missing from the API response, it’s required to ignore changes as below:

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

// ...
const group1 = new opentelekomcloud.DmsConsumerGroupV2("group1", {});

    import pulumi
import pulumi_opentelekomcloud as opentelekomcloud

# ...
group1 = opentelekomcloud.DmsConsumerGroupV2("group1")

    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 {
		// ...
		_, err := opentelekomcloud.NewDmsConsumerGroupV2(ctx, "group1", nil)
		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 group1 = new Opentelekomcloud.DmsConsumerGroupV2("group1");

});

    package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.opentelekomcloud.DmsConsumerGroupV2;
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 group1 = new DmsConsumerGroupV2("group1");

    }
}

    resources:
  group1:
    type: opentelekomcloud:DmsConsumerGroupV2

    Create DmsConsumerGroupV2 Resource

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

    Constructor syntax

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

@overload
def DmsConsumerGroupV2(resource_name: str,
                       opts: Optional[ResourceOptions] = None,
                       group_name: Optional[str] = None,
                       instance_id: Optional[str] = None,
                       description: Optional[str] = None,
                       dms_consumer_group_v2_id: Optional[str] = None)
    func NewDmsConsumerGroupV2(ctx *Context, name string, args DmsConsumerGroupV2Args, opts ...ResourceOption) (*DmsConsumerGroupV2, error)
    public DmsConsumerGroupV2(string name, DmsConsumerGroupV2Args args, CustomResourceOptions? opts = null)
    public DmsConsumerGroupV2(String name, DmsConsumerGroupV2Args args)
public DmsConsumerGroupV2(String name, DmsConsumerGroupV2Args args, CustomResourceOptions options)

    type: opentelekomcloud:DmsConsumerGroupV2
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 DmsConsumerGroupV2Args
    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 DmsConsumerGroupV2Args
    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 DmsConsumerGroupV2Args
    The arguments to resource properties.
    opts ResourceOption
    Bag of options to control resource's behavior.
    name string
    The unique name of the resource.
    args DmsConsumerGroupV2Args
    The arguments to resource properties.
    opts CustomResourceOptions
    Bag of options to control resource's behavior.
    name String
    The unique name of the resource.
    args DmsConsumerGroupV2Args
    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 dmsConsumerGroupV2Resource = new Opentelekomcloud.DmsConsumerGroupV2("dmsConsumerGroupV2Resource", new()
{
    GroupName = "string",
    InstanceId = "string",
    Description = "string",
    DmsConsumerGroupV2Id = "string",
});

    example, err := opentelekomcloud.NewDmsConsumerGroupV2(ctx, "dmsConsumerGroupV2Resource", &opentelekomcloud.DmsConsumerGroupV2Args{
	GroupName:            pulumi.String("string"),
	InstanceId:           pulumi.String("string"),
	Description:          pulumi.String("string"),
	DmsConsumerGroupV2Id: pulumi.String("string"),
})

    var dmsConsumerGroupV2Resource = new DmsConsumerGroupV2("dmsConsumerGroupV2Resource", DmsConsumerGroupV2Args.builder()
    .groupName("string")
    .instanceId("string")
    .description("string")
    .dmsConsumerGroupV2Id("string")
    .build());

    dms_consumer_group_v2_resource = opentelekomcloud.DmsConsumerGroupV2("dmsConsumerGroupV2Resource",
    group_name="string",
    instance_id="string",
    description="string",
    dms_consumer_group_v2_id="string")

    const dmsConsumerGroupV2Resource = new opentelekomcloud.DmsConsumerGroupV2("dmsConsumerGroupV2Resource", {
    groupName: "string",
    instanceId: "string",
    description: "string",
    dmsConsumerGroupV2Id: "string",
});

    type: opentelekomcloud:DmsConsumerGroupV2
properties:
    description: string
    dmsConsumerGroupV2Id: string
    groupName: string
    instanceId: string

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

    GroupName string

    Specifies the name of the DMS consumer group.

    Changing this parameter will create a new resource.

    InstanceId string

    Specifies the ID of the DMS instance.

    Changing this parameter will create a new resource.

    Description string

    Specifies any description for the DMS consumer group.

    Changing this parameter will create a new resource.

    DmsConsumerGroupV2Id string
    GroupName string

    Specifies the name of the DMS consumer group.

    Changing this parameter will create a new resource.

    InstanceId string

    Specifies the ID of the DMS instance.

    Changing this parameter will create a new resource.

    Description string

    Specifies any description for the DMS consumer group.

    Changing this parameter will create a new resource.

    DmsConsumerGroupV2Id string
    groupName String

    Specifies the name of the DMS consumer group.

    Changing this parameter will create a new resource.

    instanceId String

    Specifies the ID of the DMS instance.

    Changing this parameter will create a new resource.

    description String

    Specifies any description for the DMS consumer group.

    Changing this parameter will create a new resource.

    dmsConsumerGroupV2Id String
    groupName string

    Specifies the name of the DMS consumer group.

    Changing this parameter will create a new resource.

    instanceId string

    Specifies the ID of the DMS instance.

    Changing this parameter will create a new resource.

    description string

    Specifies any description for the DMS consumer group.

    Changing this parameter will create a new resource.

    dmsConsumerGroupV2Id string
    group_name str

    Specifies the name of the DMS consumer group.

    Changing this parameter will create a new resource.

    instance_id str

    Specifies the ID of the DMS instance.

    Changing this parameter will create a new resource.

    description str

    Specifies any description for the DMS consumer group.

    Changing this parameter will create a new resource.

    dms_consumer_group_v2_id str
    groupName String

    Specifies the name of the DMS consumer group.

    Changing this parameter will create a new resource.

    instanceId String

    Specifies the ID of the DMS instance.

    Changing this parameter will create a new resource.

    description String

    Specifies any description for the DMS consumer group.

    Changing this parameter will create a new resource.

    dmsConsumerGroupV2Id String

    Outputs

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

    AssignmentStrategy string
    Indicates the partition assignment policy.
    CoordinatorId double
    Indicates the coordinator ID.
    GroupMessageOffsets List<DmsConsumerGroupV2GroupMessageOffset>
    Indicates the consumer offset. The structure is documented below.
    Id string
    The provider-assigned unique ID for this managed resource.
    Members List<DmsConsumerGroupV2Member>
    Indicates the consumer list. The structure is documented below.
    Region string
    State string
    Indicates the Consumer group status. The value can be:

    • Dead: The consumer group has no members and no metadata.
    • Empty: The consumer group has metadata but has no members.
    • PreparingRebalance: The consumer group is to be rebalanced.
    • CompletingRebalance: All members have jointed the group.
    • Stable: Members in the consumer group can consume messages normally.
    AssignmentStrategy string
    Indicates the partition assignment policy.
    CoordinatorId float64
    Indicates the coordinator ID.
    GroupMessageOffsets []DmsConsumerGroupV2GroupMessageOffset
    Indicates the consumer offset. The structure is documented below.
    Id string
    The provider-assigned unique ID for this managed resource.
    Members []DmsConsumerGroupV2Member
    Indicates the consumer list. The structure is documented below.
    Region string
    State string
    Indicates the Consumer group status. The value can be:

    • Dead: The consumer group has no members and no metadata.
    • Empty: The consumer group has metadata but has no members.
    • PreparingRebalance: The consumer group is to be rebalanced.
    • CompletingRebalance: All members have jointed the group.
    • Stable: Members in the consumer group can consume messages normally.
    assignmentStrategy String
    Indicates the partition assignment policy.
    coordinatorId Double
    Indicates the coordinator ID.
    groupMessageOffsets List<DmsConsumerGroupV2GroupMessageOffset>
    Indicates the consumer offset. The structure is documented below.
    id String
    The provider-assigned unique ID for this managed resource.
    members List<DmsConsumerGroupV2Member>
    Indicates the consumer list. The structure is documented below.
    region String
    state String
    Indicates the Consumer group status. The value can be:

    • Dead: The consumer group has no members and no metadata.
    • Empty: The consumer group has metadata but has no members.
    • PreparingRebalance: The consumer group is to be rebalanced.
    • CompletingRebalance: All members have jointed the group.
    • Stable: Members in the consumer group can consume messages normally.
    assignmentStrategy string
    Indicates the partition assignment policy.
    coordinatorId number
    Indicates the coordinator ID.
    groupMessageOffsets DmsConsumerGroupV2GroupMessageOffset[]
    Indicates the consumer offset. The structure is documented below.
    id string
    The provider-assigned unique ID for this managed resource.
    members DmsConsumerGroupV2Member[]
    Indicates the consumer list. The structure is documented below.
    region string
    state string
    Indicates the Consumer group status. The value can be:

    • Dead: The consumer group has no members and no metadata.
    • Empty: The consumer group has metadata but has no members.
    • PreparingRebalance: The consumer group is to be rebalanced.
    • CompletingRebalance: All members have jointed the group.
    • Stable: Members in the consumer group can consume messages normally.
    assignment_strategy str
    Indicates the partition assignment policy.
    coordinator_id float
    Indicates the coordinator ID.
    group_message_offsets Sequence[DmsConsumerGroupV2GroupMessageOffset]
    Indicates the consumer offset. The structure is documented below.
    id str
    The provider-assigned unique ID for this managed resource.
    members Sequence[DmsConsumerGroupV2Member]
    Indicates the consumer list. The structure is documented below.
    region str
    state str
    Indicates the Consumer group status. The value can be:

    • Dead: The consumer group has no members and no metadata.
    • Empty: The consumer group has metadata but has no members.
    • PreparingRebalance: The consumer group is to be rebalanced.
    • CompletingRebalance: All members have jointed the group.
    • Stable: Members in the consumer group can consume messages normally.
    assignmentStrategy String
    Indicates the partition assignment policy.
    coordinatorId Number
    Indicates the coordinator ID.
    groupMessageOffsets List<Property Map>
    Indicates the consumer offset. The structure is documented below.
    id String
    The provider-assigned unique ID for this managed resource.
    members List<Property Map>
    Indicates the consumer list. The structure is documented below.
    region String
    state String
    Indicates the Consumer group status. The value can be:

    • Dead: The consumer group has no members and no metadata.
    • Empty: The consumer group has metadata but has no members.
    • PreparingRebalance: The consumer group is to be rebalanced.
    • CompletingRebalance: All members have jointed the group.
    • Stable: Members in the consumer group can consume messages normally.

    Look up Existing DmsConsumerGroupV2 Resource

    Get an existing DmsConsumerGroupV2 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?: DmsConsumerGroupV2State, opts?: CustomResourceOptions): DmsConsumerGroupV2
    @staticmethod
def get(resource_name: str,
        id: str,
        opts: Optional[ResourceOptions] = None,
        assignment_strategy: Optional[str] = None,
        coordinator_id: Optional[float] = None,
        description: Optional[str] = None,
        dms_consumer_group_v2_id: Optional[str] = None,
        group_message_offsets: Optional[Sequence[DmsConsumerGroupV2GroupMessageOffsetArgs]] = None,
        group_name: Optional[str] = None,
        instance_id: Optional[str] = None,
        members: Optional[Sequence[DmsConsumerGroupV2MemberArgs]] = None,
        region: Optional[str] = None,
        state: Optional[str] = None) -> DmsConsumerGroupV2
    func GetDmsConsumerGroupV2(ctx *Context, name string, id IDInput, state *DmsConsumerGroupV2State, opts ...ResourceOption) (*DmsConsumerGroupV2, error)
    public static DmsConsumerGroupV2 Get(string name, Input<string> id, DmsConsumerGroupV2State? state, CustomResourceOptions? opts = null)
    public static DmsConsumerGroupV2 get(String name, Output<String> id, DmsConsumerGroupV2State state, CustomResourceOptions options)
    resources:  _:    type: opentelekomcloud:DmsConsumerGroupV2    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:
    AssignmentStrategy string
    Indicates the partition assignment policy.
    CoordinatorId double
    Indicates the coordinator ID.
    Description string

    Specifies any description for the DMS consumer group.

    Changing this parameter will create a new resource.

    DmsConsumerGroupV2Id string
    GroupMessageOffsets List<DmsConsumerGroupV2GroupMessageOffset>
    Indicates the consumer offset. The structure is documented below.
    GroupName string

    Specifies the name of the DMS consumer group.

    Changing this parameter will create a new resource.

    InstanceId string

    Specifies the ID of the DMS instance.

    Changing this parameter will create a new resource.

    Members List<DmsConsumerGroupV2Member>
    Indicates the consumer list. The structure is documented below.
    Region string
    State string
    Indicates the Consumer group status. The value can be:

    • Dead: The consumer group has no members and no metadata.
    • Empty: The consumer group has metadata but has no members.
    • PreparingRebalance: The consumer group is to be rebalanced.
    • CompletingRebalance: All members have jointed the group.
    • Stable: Members in the consumer group can consume messages normally.
    AssignmentStrategy string
    Indicates the partition assignment policy.
    CoordinatorId float64
    Indicates the coordinator ID.
    Description string

    Specifies any description for the DMS consumer group.

    Changing this parameter will create a new resource.

    DmsConsumerGroupV2Id string
    GroupMessageOffsets []DmsConsumerGroupV2GroupMessageOffsetArgs
    Indicates the consumer offset. The structure is documented below.
    GroupName string

    Specifies the name of the DMS consumer group.

    Changing this parameter will create a new resource.

    InstanceId string

    Specifies the ID of the DMS instance.

    Changing this parameter will create a new resource.

    Members []DmsConsumerGroupV2MemberArgs
    Indicates the consumer list. The structure is documented below.
    Region string
    State string
    Indicates the Consumer group status. The value can be:

    • Dead: The consumer group has no members and no metadata.
    • Empty: The consumer group has metadata but has no members.
    • PreparingRebalance: The consumer group is to be rebalanced.
    • CompletingRebalance: All members have jointed the group.
    • Stable: Members in the consumer group can consume messages normally.
    assignmentStrategy String
    Indicates the partition assignment policy.
    coordinatorId Double
    Indicates the coordinator ID.
    description String

    Specifies any description for the DMS consumer group.

    Changing this parameter will create a new resource.

    dmsConsumerGroupV2Id String
    groupMessageOffsets List<DmsConsumerGroupV2GroupMessageOffset>
    Indicates the consumer offset. The structure is documented below.
    groupName String

    Specifies the name of the DMS consumer group.

    Changing this parameter will create a new resource.

    instanceId String

    Specifies the ID of the DMS instance.

    Changing this parameter will create a new resource.

    members List<DmsConsumerGroupV2Member>
    Indicates the consumer list. The structure is documented below.
    region String
    state String
    Indicates the Consumer group status. The value can be:

    • Dead: The consumer group has no members and no metadata.
    • Empty: The consumer group has metadata but has no members.
    • PreparingRebalance: The consumer group is to be rebalanced.
    • CompletingRebalance: All members have jointed the group.
    • Stable: Members in the consumer group can consume messages normally.
    assignmentStrategy string
    Indicates the partition assignment policy.
    coordinatorId number
    Indicates the coordinator ID.
    description string

    Specifies any description for the DMS consumer group.

    Changing this parameter will create a new resource.

    dmsConsumerGroupV2Id string
    groupMessageOffsets DmsConsumerGroupV2GroupMessageOffset[]
    Indicates the consumer offset. The structure is documented below.
    groupName string

    Specifies the name of the DMS consumer group.

    Changing this parameter will create a new resource.

    instanceId string

    Specifies the ID of the DMS instance.

    Changing this parameter will create a new resource.

    members DmsConsumerGroupV2Member[]
    Indicates the consumer list. The structure is documented below.
    region string
    state string
    Indicates the Consumer group status. The value can be:

    • Dead: The consumer group has no members and no metadata.
    • Empty: The consumer group has metadata but has no members.
    • PreparingRebalance: The consumer group is to be rebalanced.
    • CompletingRebalance: All members have jointed the group.
    • Stable: Members in the consumer group can consume messages normally.
    assignment_strategy str
    Indicates the partition assignment policy.
    coordinator_id float
    Indicates the coordinator ID.
    description str

    Specifies any description for the DMS consumer group.

    Changing this parameter will create a new resource.

    dms_consumer_group_v2_id str
    group_message_offsets Sequence[DmsConsumerGroupV2GroupMessageOffsetArgs]
    Indicates the consumer offset. The structure is documented below.
    group_name str

    Specifies the name of the DMS consumer group.

    Changing this parameter will create a new resource.

    instance_id str

    Specifies the ID of the DMS instance.

    Changing this parameter will create a new resource.

    members Sequence[DmsConsumerGroupV2MemberArgs]
    Indicates the consumer list. The structure is documented below.
    region str
    state str
    Indicates the Consumer group status. The value can be:

    • Dead: The consumer group has no members and no metadata.
    • Empty: The consumer group has metadata but has no members.
    • PreparingRebalance: The consumer group is to be rebalanced.
    • CompletingRebalance: All members have jointed the group.
    • Stable: Members in the consumer group can consume messages normally.
    assignmentStrategy String
    Indicates the partition assignment policy.
    coordinatorId Number
    Indicates the coordinator ID.
    description String

    Specifies any description for the DMS consumer group.

    Changing this parameter will create a new resource.

    dmsConsumerGroupV2Id String
    groupMessageOffsets List<Property Map>
    Indicates the consumer offset. The structure is documented below.
    groupName String

    Specifies the name of the DMS consumer group.

    Changing this parameter will create a new resource.

    instanceId String

    Specifies the ID of the DMS instance.

    Changing this parameter will create a new resource.

    members List<Property Map>
    Indicates the consumer list. The structure is documented below.
    region String
    state String
    Indicates the Consumer group status. The value can be:

    • Dead: The consumer group has no members and no metadata.
    • Empty: The consumer group has metadata but has no members.
    • PreparingRebalance: The consumer group is to be rebalanced.
    • CompletingRebalance: All members have jointed the group.
    • Stable: Members in the consumer group can consume messages normally.

    Supporting Types

    DmsConsumerGroupV2GroupMessageOffset, DmsConsumerGroupV2GroupMessageOffsetArgs

    Lag double
    Indicates the number of remaining messages that can be retrieved, that is, the number of accumulated messages.
    MessageCurrentOffset double
    Indicates the consumer offset.
    MessageLogEndOffset double
    Indicates the log end offset (LEO).
    Partition double
    Indicates the partition number.
    Topic string
    Indicates the topic name.
    Lag float64
    Indicates the number of remaining messages that can be retrieved, that is, the number of accumulated messages.
    MessageCurrentOffset float64
    Indicates the consumer offset.
    MessageLogEndOffset float64
    Indicates the log end offset (LEO).
    Partition float64
    Indicates the partition number.
    Topic string
    Indicates the topic name.
    lag Double
    Indicates the number of remaining messages that can be retrieved, that is, the number of accumulated messages.
    messageCurrentOffset Double
    Indicates the consumer offset.
    messageLogEndOffset Double
    Indicates the log end offset (LEO).
    partition Double
    Indicates the partition number.
    topic String
    Indicates the topic name.
    lag number
    Indicates the number of remaining messages that can be retrieved, that is, the number of accumulated messages.
    messageCurrentOffset number
    Indicates the consumer offset.
    messageLogEndOffset number
    Indicates the log end offset (LEO).
    partition number
    Indicates the partition number.
    topic string
    Indicates the topic name.
    lag float
    Indicates the number of remaining messages that can be retrieved, that is, the number of accumulated messages.
    message_current_offset float
    Indicates the consumer offset.
    message_log_end_offset float
    Indicates the log end offset (LEO).
    partition float
    Indicates the partition number.
    topic str
    Indicates the topic name.
    lag Number
    Indicates the number of remaining messages that can be retrieved, that is, the number of accumulated messages.
    messageCurrentOffset Number
    Indicates the consumer offset.
    messageLogEndOffset Number
    Indicates the log end offset (LEO).
    partition Number
    Indicates the partition number.
    topic String
    Indicates the topic name.

    DmsConsumerGroupV2Member, DmsConsumerGroupV2MemberArgs

    Assignments List<DmsConsumerGroupV2MemberAssignment>
    Indicates the details about the partition assigned to the consumer. The structure is as follows:
    ClientId string
    Indicates the client ID.
    Host string
    Indicates the consumer address.
    MemberId string
    Indicates the consumer ID.
    Assignments []DmsConsumerGroupV2MemberAssignment
    Indicates the details about the partition assigned to the consumer. The structure is as follows:
    ClientId string
    Indicates the client ID.
    Host string
    Indicates the consumer address.
    MemberId string
    Indicates the consumer ID.
    assignments List<DmsConsumerGroupV2MemberAssignment>
    Indicates the details about the partition assigned to the consumer. The structure is as follows:
    clientId String
    Indicates the client ID.
    host String
    Indicates the consumer address.
    memberId String
    Indicates the consumer ID.
    assignments DmsConsumerGroupV2MemberAssignment[]
    Indicates the details about the partition assigned to the consumer. The structure is as follows:
    clientId string
    Indicates the client ID.
    host string
    Indicates the consumer address.
    memberId string
    Indicates the consumer ID.
    assignments Sequence[DmsConsumerGroupV2MemberAssignment]
    Indicates the details about the partition assigned to the consumer. The structure is as follows:
    client_id str
    Indicates the client ID.
    host str
    Indicates the consumer address.
    member_id str
    Indicates the consumer ID.
    assignments List<Property Map>
    Indicates the details about the partition assigned to the consumer. The structure is as follows:
    clientId String
    Indicates the client ID.
    host String
    Indicates the consumer address.
    memberId String
    Indicates the consumer ID.

    DmsConsumerGroupV2MemberAssignment, DmsConsumerGroupV2MemberAssignmentArgs

    Partitions List<double>
    Indicates the partition list.
    Topic string
    Indicates the topic name.
    Partitions []float64
    Indicates the partition list.
    Topic string
    Indicates the topic name.
    partitions List<Double>
    Indicates the partition list.
    topic String
    Indicates the topic name.
    partitions number[]
    Indicates the partition list.
    topic string
    Indicates the topic name.
    partitions Sequence[float]
    Indicates the partition list.
    topic str
    Indicates the topic name.
    partitions List<Number>
    Indicates the partition list.
    topic String
    Indicates the topic name.

    Import

    DMS consumer groups can be imported using their group_name and related instance_id, separated by a slash, e.g.

    bash

    $ pulumi import opentelekomcloud:index/dmsConsumerGroupV2:DmsConsumerGroupV2 test_group <instance_id>/<group_name>

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

    Package Details

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