1. Packages
  2. Tencentcloud Provider
  3. API Docs
  4. CkafkaConsumerGroupModifyOffset
tencentcloud 1.81.189 published on Wednesday, Apr 30, 2025 by tencentcloudstack

tencentcloud.CkafkaConsumerGroupModifyOffset

Explore with Pulumi AI

tencentcloud logo
tencentcloud 1.81.189 published on Wednesday, Apr 30, 2025 by tencentcloudstack

    Provides a resource to create a ckafka consumer_group_modify_offset

    Example Usage

    import * as pulumi from "@pulumi/pulumi";
    import * as tencentcloud from "@pulumi/tencentcloud";
    
    const consumerGroupModifyOffset = new tencentcloud.CkafkaConsumerGroupModifyOffset("consumerGroupModifyOffset", {
        group: "xxxxxx",
        instanceId: "ckafka-xxxxxx",
        offset: 0,
        strategy: 2,
        topics: ["xxxxxx"],
    });
    
    import pulumi
    import pulumi_tencentcloud as tencentcloud
    
    consumer_group_modify_offset = tencentcloud.CkafkaConsumerGroupModifyOffset("consumerGroupModifyOffset",
        group="xxxxxx",
        instance_id="ckafka-xxxxxx",
        offset=0,
        strategy=2,
        topics=["xxxxxx"])
    
    package main
    
    import (
    	"github.com/pulumi/pulumi-terraform-provider/sdks/go/tencentcloud/tencentcloud"
    	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
    )
    
    func main() {
    	pulumi.Run(func(ctx *pulumi.Context) error {
    		_, err := tencentcloud.NewCkafkaConsumerGroupModifyOffset(ctx, "consumerGroupModifyOffset", &tencentcloud.CkafkaConsumerGroupModifyOffsetArgs{
    			Group:      pulumi.String("xxxxxx"),
    			InstanceId: pulumi.String("ckafka-xxxxxx"),
    			Offset:     pulumi.Float64(0),
    			Strategy:   pulumi.Float64(2),
    			Topics: pulumi.StringArray{
    				pulumi.String("xxxxxx"),
    			},
    		})
    		if err != nil {
    			return err
    		}
    		return nil
    	})
    }
    
    using System.Collections.Generic;
    using System.Linq;
    using Pulumi;
    using Tencentcloud = Pulumi.Tencentcloud;
    
    return await Deployment.RunAsync(() => 
    {
        var consumerGroupModifyOffset = new Tencentcloud.CkafkaConsumerGroupModifyOffset("consumerGroupModifyOffset", new()
        {
            Group = "xxxxxx",
            InstanceId = "ckafka-xxxxxx",
            Offset = 0,
            Strategy = 2,
            Topics = new[]
            {
                "xxxxxx",
            },
        });
    
    });
    
    package generated_program;
    
    import com.pulumi.Context;
    import com.pulumi.Pulumi;
    import com.pulumi.core.Output;
    import com.pulumi.tencentcloud.CkafkaConsumerGroupModifyOffset;
    import com.pulumi.tencentcloud.CkafkaConsumerGroupModifyOffsetArgs;
    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 consumerGroupModifyOffset = new CkafkaConsumerGroupModifyOffset("consumerGroupModifyOffset", CkafkaConsumerGroupModifyOffsetArgs.builder()
                .group("xxxxxx")
                .instanceId("ckafka-xxxxxx")
                .offset(0)
                .strategy(2)
                .topics("xxxxxx")
                .build());
    
        }
    }
    
    resources:
      consumerGroupModifyOffset:
        type: tencentcloud:CkafkaConsumerGroupModifyOffset
        properties:
          group: xxxxxx
          instanceId: ckafka-xxxxxx
          offset: 0
          strategy: 2
          topics:
            - xxxxxx
    

    Create CkafkaConsumerGroupModifyOffset Resource

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

    Constructor syntax

    new CkafkaConsumerGroupModifyOffset(name: string, args: CkafkaConsumerGroupModifyOffsetArgs, opts?: CustomResourceOptions);
    @overload
    def CkafkaConsumerGroupModifyOffset(resource_name: str,
                                        args: CkafkaConsumerGroupModifyOffsetArgs,
                                        opts: Optional[ResourceOptions] = None)
    
    @overload
    def CkafkaConsumerGroupModifyOffset(resource_name: str,
                                        opts: Optional[ResourceOptions] = None,
                                        group: Optional[str] = None,
                                        instance_id: Optional[str] = None,
                                        strategy: Optional[float] = None,
                                        ckafka_consumer_group_modify_offset_id: Optional[str] = None,
                                        offset: Optional[float] = None,
                                        partitions: Optional[Sequence[float]] = None,
                                        shift: Optional[float] = None,
                                        shift_timestamp: Optional[float] = None,
                                        topics: Optional[Sequence[str]] = None)
    func NewCkafkaConsumerGroupModifyOffset(ctx *Context, name string, args CkafkaConsumerGroupModifyOffsetArgs, opts ...ResourceOption) (*CkafkaConsumerGroupModifyOffset, error)
    public CkafkaConsumerGroupModifyOffset(string name, CkafkaConsumerGroupModifyOffsetArgs args, CustomResourceOptions? opts = null)
    public CkafkaConsumerGroupModifyOffset(String name, CkafkaConsumerGroupModifyOffsetArgs args)
    public CkafkaConsumerGroupModifyOffset(String name, CkafkaConsumerGroupModifyOffsetArgs args, CustomResourceOptions options)
    
    type: tencentcloud:CkafkaConsumerGroupModifyOffset
    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 CkafkaConsumerGroupModifyOffsetArgs
    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 CkafkaConsumerGroupModifyOffsetArgs
    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 CkafkaConsumerGroupModifyOffsetArgs
    The arguments to resource properties.
    opts ResourceOption
    Bag of options to control resource's behavior.
    name string
    The unique name of the resource.
    args CkafkaConsumerGroupModifyOffsetArgs
    The arguments to resource properties.
    opts CustomResourceOptions
    Bag of options to control resource's behavior.
    name String
    The unique name of the resource.
    args CkafkaConsumerGroupModifyOffsetArgs
    The arguments to resource properties.
    options CustomResourceOptions
    Bag of options to control resource's behavior.

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

    Group string
    kafka group.
    InstanceId string
    Kafka instance id.
    Strategy double
    Reset the policy of offset. 0: Move the offset forward or backward shift bar; 1: Alignment reference (by-duration,to-datetime,to-earliest,to-latest), which means moving the offset to the location of the specified timestamp; 2: Alignment reference (to-offset), which means to move the offset to the specified offset location.
    CkafkaConsumerGroupModifyOffsetId string
    ID of the resource.
    Offset double
    The offset location that needs to be reset. When strategy is 2, this field must be included.
    Partitions List<double>
    The list of partition that needs to be reset if no Topics parameter is specified. Resets the partition in the corresponding Partition list of all topics. When Topics is specified, the partition of the corresponding topic list of the specified Partitions list is reset.
    Shift double
    This field must be included when strategy is 0. If it is greater than zero, the offset will be moved backward by shift bars, and if it is less than zero, the offset will be traced back to the number of shift entries. After the correct reset, the new offset should be (old_offset + shift). It should be noted that if the new offset is less than partition's earliest, it will be set to earliest, and if the latest greater than partition will be set to latest.
    ShiftTimestamp double
    Unit ms. When strategy is 1, you must include this field, where-2 means to reset the offset to the beginning,-1 means to reset to the latest position (equivalent to emptying), and other values represent the specified time. You will get the offset of the specified time in the topic and then reset it. If there is no message at the specified time, get the last offset.
    Topics List<string>
    Indicates the topics that needs to be reset. Leave it empty means all.
    Group string
    kafka group.
    InstanceId string
    Kafka instance id.
    Strategy float64
    Reset the policy of offset. 0: Move the offset forward or backward shift bar; 1: Alignment reference (by-duration,to-datetime,to-earliest,to-latest), which means moving the offset to the location of the specified timestamp; 2: Alignment reference (to-offset), which means to move the offset to the specified offset location.
    CkafkaConsumerGroupModifyOffsetId string
    ID of the resource.
    Offset float64
    The offset location that needs to be reset. When strategy is 2, this field must be included.
    Partitions []float64
    The list of partition that needs to be reset if no Topics parameter is specified. Resets the partition in the corresponding Partition list of all topics. When Topics is specified, the partition of the corresponding topic list of the specified Partitions list is reset.
    Shift float64
    This field must be included when strategy is 0. If it is greater than zero, the offset will be moved backward by shift bars, and if it is less than zero, the offset will be traced back to the number of shift entries. After the correct reset, the new offset should be (old_offset + shift). It should be noted that if the new offset is less than partition's earliest, it will be set to earliest, and if the latest greater than partition will be set to latest.
    ShiftTimestamp float64
    Unit ms. When strategy is 1, you must include this field, where-2 means to reset the offset to the beginning,-1 means to reset to the latest position (equivalent to emptying), and other values represent the specified time. You will get the offset of the specified time in the topic and then reset it. If there is no message at the specified time, get the last offset.
    Topics []string
    Indicates the topics that needs to be reset. Leave it empty means all.
    group String
    kafka group.
    instanceId String
    Kafka instance id.
    strategy Double
    Reset the policy of offset. 0: Move the offset forward or backward shift bar; 1: Alignment reference (by-duration,to-datetime,to-earliest,to-latest), which means moving the offset to the location of the specified timestamp; 2: Alignment reference (to-offset), which means to move the offset to the specified offset location.
    ckafkaConsumerGroupModifyOffsetId String
    ID of the resource.
    offset Double
    The offset location that needs to be reset. When strategy is 2, this field must be included.
    partitions List<Double>
    The list of partition that needs to be reset if no Topics parameter is specified. Resets the partition in the corresponding Partition list of all topics. When Topics is specified, the partition of the corresponding topic list of the specified Partitions list is reset.
    shift Double
    This field must be included when strategy is 0. If it is greater than zero, the offset will be moved backward by shift bars, and if it is less than zero, the offset will be traced back to the number of shift entries. After the correct reset, the new offset should be (old_offset + shift). It should be noted that if the new offset is less than partition's earliest, it will be set to earliest, and if the latest greater than partition will be set to latest.
    shiftTimestamp Double
    Unit ms. When strategy is 1, you must include this field, where-2 means to reset the offset to the beginning,-1 means to reset to the latest position (equivalent to emptying), and other values represent the specified time. You will get the offset of the specified time in the topic and then reset it. If there is no message at the specified time, get the last offset.
    topics List<String>
    Indicates the topics that needs to be reset. Leave it empty means all.
    group string
    kafka group.
    instanceId string
    Kafka instance id.
    strategy number
    Reset the policy of offset. 0: Move the offset forward or backward shift bar; 1: Alignment reference (by-duration,to-datetime,to-earliest,to-latest), which means moving the offset to the location of the specified timestamp; 2: Alignment reference (to-offset), which means to move the offset to the specified offset location.
    ckafkaConsumerGroupModifyOffsetId string
    ID of the resource.
    offset number
    The offset location that needs to be reset. When strategy is 2, this field must be included.
    partitions number[]
    The list of partition that needs to be reset if no Topics parameter is specified. Resets the partition in the corresponding Partition list of all topics. When Topics is specified, the partition of the corresponding topic list of the specified Partitions list is reset.
    shift number
    This field must be included when strategy is 0. If it is greater than zero, the offset will be moved backward by shift bars, and if it is less than zero, the offset will be traced back to the number of shift entries. After the correct reset, the new offset should be (old_offset + shift). It should be noted that if the new offset is less than partition's earliest, it will be set to earliest, and if the latest greater than partition will be set to latest.
    shiftTimestamp number
    Unit ms. When strategy is 1, you must include this field, where-2 means to reset the offset to the beginning,-1 means to reset to the latest position (equivalent to emptying), and other values represent the specified time. You will get the offset of the specified time in the topic and then reset it. If there is no message at the specified time, get the last offset.
    topics string[]
    Indicates the topics that needs to be reset. Leave it empty means all.
    group str
    kafka group.
    instance_id str
    Kafka instance id.
    strategy float
    Reset the policy of offset. 0: Move the offset forward or backward shift bar; 1: Alignment reference (by-duration,to-datetime,to-earliest,to-latest), which means moving the offset to the location of the specified timestamp; 2: Alignment reference (to-offset), which means to move the offset to the specified offset location.
    ckafka_consumer_group_modify_offset_id str
    ID of the resource.
    offset float
    The offset location that needs to be reset. When strategy is 2, this field must be included.
    partitions Sequence[float]
    The list of partition that needs to be reset if no Topics parameter is specified. Resets the partition in the corresponding Partition list of all topics. When Topics is specified, the partition of the corresponding topic list of the specified Partitions list is reset.
    shift float
    This field must be included when strategy is 0. If it is greater than zero, the offset will be moved backward by shift bars, and if it is less than zero, the offset will be traced back to the number of shift entries. After the correct reset, the new offset should be (old_offset + shift). It should be noted that if the new offset is less than partition's earliest, it will be set to earliest, and if the latest greater than partition will be set to latest.
    shift_timestamp float
    Unit ms. When strategy is 1, you must include this field, where-2 means to reset the offset to the beginning,-1 means to reset to the latest position (equivalent to emptying), and other values represent the specified time. You will get the offset of the specified time in the topic and then reset it. If there is no message at the specified time, get the last offset.
    topics Sequence[str]
    Indicates the topics that needs to be reset. Leave it empty means all.
    group String
    kafka group.
    instanceId String
    Kafka instance id.
    strategy Number
    Reset the policy of offset. 0: Move the offset forward or backward shift bar; 1: Alignment reference (by-duration,to-datetime,to-earliest,to-latest), which means moving the offset to the location of the specified timestamp; 2: Alignment reference (to-offset), which means to move the offset to the specified offset location.
    ckafkaConsumerGroupModifyOffsetId String
    ID of the resource.
    offset Number
    The offset location that needs to be reset. When strategy is 2, this field must be included.
    partitions List<Number>
    The list of partition that needs to be reset if no Topics parameter is specified. Resets the partition in the corresponding Partition list of all topics. When Topics is specified, the partition of the corresponding topic list of the specified Partitions list is reset.
    shift Number
    This field must be included when strategy is 0. If it is greater than zero, the offset will be moved backward by shift bars, and if it is less than zero, the offset will be traced back to the number of shift entries. After the correct reset, the new offset should be (old_offset + shift). It should be noted that if the new offset is less than partition's earliest, it will be set to earliest, and if the latest greater than partition will be set to latest.
    shiftTimestamp Number
    Unit ms. When strategy is 1, you must include this field, where-2 means to reset the offset to the beginning,-1 means to reset to the latest position (equivalent to emptying), and other values represent the specified time. You will get the offset of the specified time in the topic and then reset it. If there is no message at the specified time, get the last offset.
    topics List<String>
    Indicates the topics that needs to be reset. Leave it empty means all.

    Outputs

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

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

    Look up Existing CkafkaConsumerGroupModifyOffset Resource

    Get an existing CkafkaConsumerGroupModifyOffset 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?: CkafkaConsumerGroupModifyOffsetState, opts?: CustomResourceOptions): CkafkaConsumerGroupModifyOffset
    @staticmethod
    def get(resource_name: str,
            id: str,
            opts: Optional[ResourceOptions] = None,
            ckafka_consumer_group_modify_offset_id: Optional[str] = None,
            group: Optional[str] = None,
            instance_id: Optional[str] = None,
            offset: Optional[float] = None,
            partitions: Optional[Sequence[float]] = None,
            shift: Optional[float] = None,
            shift_timestamp: Optional[float] = None,
            strategy: Optional[float] = None,
            topics: Optional[Sequence[str]] = None) -> CkafkaConsumerGroupModifyOffset
    func GetCkafkaConsumerGroupModifyOffset(ctx *Context, name string, id IDInput, state *CkafkaConsumerGroupModifyOffsetState, opts ...ResourceOption) (*CkafkaConsumerGroupModifyOffset, error)
    public static CkafkaConsumerGroupModifyOffset Get(string name, Input<string> id, CkafkaConsumerGroupModifyOffsetState? state, CustomResourceOptions? opts = null)
    public static CkafkaConsumerGroupModifyOffset get(String name, Output<String> id, CkafkaConsumerGroupModifyOffsetState state, CustomResourceOptions options)
    resources:  _:    type: tencentcloud:CkafkaConsumerGroupModifyOffset    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:
    CkafkaConsumerGroupModifyOffsetId string
    ID of the resource.
    Group string
    kafka group.
    InstanceId string
    Kafka instance id.
    Offset double
    The offset location that needs to be reset. When strategy is 2, this field must be included.
    Partitions List<double>
    The list of partition that needs to be reset if no Topics parameter is specified. Resets the partition in the corresponding Partition list of all topics. When Topics is specified, the partition of the corresponding topic list of the specified Partitions list is reset.
    Shift double
    This field must be included when strategy is 0. If it is greater than zero, the offset will be moved backward by shift bars, and if it is less than zero, the offset will be traced back to the number of shift entries. After the correct reset, the new offset should be (old_offset + shift). It should be noted that if the new offset is less than partition's earliest, it will be set to earliest, and if the latest greater than partition will be set to latest.
    ShiftTimestamp double
    Unit ms. When strategy is 1, you must include this field, where-2 means to reset the offset to the beginning,-1 means to reset to the latest position (equivalent to emptying), and other values represent the specified time. You will get the offset of the specified time in the topic and then reset it. If there is no message at the specified time, get the last offset.
    Strategy double
    Reset the policy of offset. 0: Move the offset forward or backward shift bar; 1: Alignment reference (by-duration,to-datetime,to-earliest,to-latest), which means moving the offset to the location of the specified timestamp; 2: Alignment reference (to-offset), which means to move the offset to the specified offset location.
    Topics List<string>
    Indicates the topics that needs to be reset. Leave it empty means all.
    CkafkaConsumerGroupModifyOffsetId string
    ID of the resource.
    Group string
    kafka group.
    InstanceId string
    Kafka instance id.
    Offset float64
    The offset location that needs to be reset. When strategy is 2, this field must be included.
    Partitions []float64
    The list of partition that needs to be reset if no Topics parameter is specified. Resets the partition in the corresponding Partition list of all topics. When Topics is specified, the partition of the corresponding topic list of the specified Partitions list is reset.
    Shift float64
    This field must be included when strategy is 0. If it is greater than zero, the offset will be moved backward by shift bars, and if it is less than zero, the offset will be traced back to the number of shift entries. After the correct reset, the new offset should be (old_offset + shift). It should be noted that if the new offset is less than partition's earliest, it will be set to earliest, and if the latest greater than partition will be set to latest.
    ShiftTimestamp float64
    Unit ms. When strategy is 1, you must include this field, where-2 means to reset the offset to the beginning,-1 means to reset to the latest position (equivalent to emptying), and other values represent the specified time. You will get the offset of the specified time in the topic and then reset it. If there is no message at the specified time, get the last offset.
    Strategy float64
    Reset the policy of offset. 0: Move the offset forward or backward shift bar; 1: Alignment reference (by-duration,to-datetime,to-earliest,to-latest), which means moving the offset to the location of the specified timestamp; 2: Alignment reference (to-offset), which means to move the offset to the specified offset location.
    Topics []string
    Indicates the topics that needs to be reset. Leave it empty means all.
    ckafkaConsumerGroupModifyOffsetId String
    ID of the resource.
    group String
    kafka group.
    instanceId String
    Kafka instance id.
    offset Double
    The offset location that needs to be reset. When strategy is 2, this field must be included.
    partitions List<Double>
    The list of partition that needs to be reset if no Topics parameter is specified. Resets the partition in the corresponding Partition list of all topics. When Topics is specified, the partition of the corresponding topic list of the specified Partitions list is reset.
    shift Double
    This field must be included when strategy is 0. If it is greater than zero, the offset will be moved backward by shift bars, and if it is less than zero, the offset will be traced back to the number of shift entries. After the correct reset, the new offset should be (old_offset + shift). It should be noted that if the new offset is less than partition's earliest, it will be set to earliest, and if the latest greater than partition will be set to latest.
    shiftTimestamp Double
    Unit ms. When strategy is 1, you must include this field, where-2 means to reset the offset to the beginning,-1 means to reset to the latest position (equivalent to emptying), and other values represent the specified time. You will get the offset of the specified time in the topic and then reset it. If there is no message at the specified time, get the last offset.
    strategy Double
    Reset the policy of offset. 0: Move the offset forward or backward shift bar; 1: Alignment reference (by-duration,to-datetime,to-earliest,to-latest), which means moving the offset to the location of the specified timestamp; 2: Alignment reference (to-offset), which means to move the offset to the specified offset location.
    topics List<String>
    Indicates the topics that needs to be reset. Leave it empty means all.
    ckafkaConsumerGroupModifyOffsetId string
    ID of the resource.
    group string
    kafka group.
    instanceId string
    Kafka instance id.
    offset number
    The offset location that needs to be reset. When strategy is 2, this field must be included.
    partitions number[]
    The list of partition that needs to be reset if no Topics parameter is specified. Resets the partition in the corresponding Partition list of all topics. When Topics is specified, the partition of the corresponding topic list of the specified Partitions list is reset.
    shift number
    This field must be included when strategy is 0. If it is greater than zero, the offset will be moved backward by shift bars, and if it is less than zero, the offset will be traced back to the number of shift entries. After the correct reset, the new offset should be (old_offset + shift). It should be noted that if the new offset is less than partition's earliest, it will be set to earliest, and if the latest greater than partition will be set to latest.
    shiftTimestamp number
    Unit ms. When strategy is 1, you must include this field, where-2 means to reset the offset to the beginning,-1 means to reset to the latest position (equivalent to emptying), and other values represent the specified time. You will get the offset of the specified time in the topic and then reset it. If there is no message at the specified time, get the last offset.
    strategy number
    Reset the policy of offset. 0: Move the offset forward or backward shift bar; 1: Alignment reference (by-duration,to-datetime,to-earliest,to-latest), which means moving the offset to the location of the specified timestamp; 2: Alignment reference (to-offset), which means to move the offset to the specified offset location.
    topics string[]
    Indicates the topics that needs to be reset. Leave it empty means all.
    ckafka_consumer_group_modify_offset_id str
    ID of the resource.
    group str
    kafka group.
    instance_id str
    Kafka instance id.
    offset float
    The offset location that needs to be reset. When strategy is 2, this field must be included.
    partitions Sequence[float]
    The list of partition that needs to be reset if no Topics parameter is specified. Resets the partition in the corresponding Partition list of all topics. When Topics is specified, the partition of the corresponding topic list of the specified Partitions list is reset.
    shift float
    This field must be included when strategy is 0. If it is greater than zero, the offset will be moved backward by shift bars, and if it is less than zero, the offset will be traced back to the number of shift entries. After the correct reset, the new offset should be (old_offset + shift). It should be noted that if the new offset is less than partition's earliest, it will be set to earliest, and if the latest greater than partition will be set to latest.
    shift_timestamp float
    Unit ms. When strategy is 1, you must include this field, where-2 means to reset the offset to the beginning,-1 means to reset to the latest position (equivalent to emptying), and other values represent the specified time. You will get the offset of the specified time in the topic and then reset it. If there is no message at the specified time, get the last offset.
    strategy float
    Reset the policy of offset. 0: Move the offset forward or backward shift bar; 1: Alignment reference (by-duration,to-datetime,to-earliest,to-latest), which means moving the offset to the location of the specified timestamp; 2: Alignment reference (to-offset), which means to move the offset to the specified offset location.
    topics Sequence[str]
    Indicates the topics that needs to be reset. Leave it empty means all.
    ckafkaConsumerGroupModifyOffsetId String
    ID of the resource.
    group String
    kafka group.
    instanceId String
    Kafka instance id.
    offset Number
    The offset location that needs to be reset. When strategy is 2, this field must be included.
    partitions List<Number>
    The list of partition that needs to be reset if no Topics parameter is specified. Resets the partition in the corresponding Partition list of all topics. When Topics is specified, the partition of the corresponding topic list of the specified Partitions list is reset.
    shift Number
    This field must be included when strategy is 0. If it is greater than zero, the offset will be moved backward by shift bars, and if it is less than zero, the offset will be traced back to the number of shift entries. After the correct reset, the new offset should be (old_offset + shift). It should be noted that if the new offset is less than partition's earliest, it will be set to earliest, and if the latest greater than partition will be set to latest.
    shiftTimestamp Number
    Unit ms. When strategy is 1, you must include this field, where-2 means to reset the offset to the beginning,-1 means to reset to the latest position (equivalent to emptying), and other values represent the specified time. You will get the offset of the specified time in the topic and then reset it. If there is no message at the specified time, get the last offset.
    strategy Number
    Reset the policy of offset. 0: Move the offset forward or backward shift bar; 1: Alignment reference (by-duration,to-datetime,to-earliest,to-latest), which means moving the offset to the location of the specified timestamp; 2: Alignment reference (to-offset), which means to move the offset to the specified offset location.
    topics List<String>
    Indicates the topics that needs to be reset. Leave it empty means all.

    Package Details

    Repository
    tencentcloud tencentcloudstack/terraform-provider-tencentcloud
    License
    Notes
    This Pulumi package is based on the tencentcloud Terraform Provider.
    tencentcloud logo
    tencentcloud 1.81.189 published on Wednesday, Apr 30, 2025 by tencentcloudstack