tencentcloud.CkafkaConsumerGroupModifyOffset
Explore with Pulumi AI
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.
- Instance
Id 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. - Ckafka
Consumer stringGroup Modify Offset Id - 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.
- Shift
Timestamp 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.
- Instance
Id 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. - Ckafka
Consumer stringGroup Modify Offset Id - 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.
- Shift
Timestamp 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.
- instance
Id 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. - ckafka
Consumer StringGroup Modify Offset Id - 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.
- shift
Timestamp 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.
- instance
Id 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. - ckafka
Consumer stringGroup Modify Offset Id - 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.
- shift
Timestamp 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_ strgroup_ modify_ offset_ id - 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.
- instance
Id 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. - ckafka
Consumer StringGroup Modify Offset Id - 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.
- shift
Timestamp 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.
- Ckafka
Consumer stringGroup Modify Offset Id - ID of the resource.
- Group string
- kafka group.
- Instance
Id 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.
- Shift
Timestamp 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.
- Ckafka
Consumer stringGroup Modify Offset Id - ID of the resource.
- Group string
- kafka group.
- Instance
Id 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.
- Shift
Timestamp 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.
- ckafka
Consumer StringGroup Modify Offset Id - ID of the resource.
- group String
- kafka group.
- instance
Id 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.
- shift
Timestamp 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.
- ckafka
Consumer stringGroup Modify Offset Id - ID of the resource.
- group string
- kafka group.
- instance
Id 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.
- shift
Timestamp 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_ strgroup_ modify_ offset_ id - 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.
- ckafka
Consumer StringGroup Modify Offset Id - ID of the resource.
- group String
- kafka group.
- instance
Id 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.
- shift
Timestamp 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.