tencentcloud 1.81.189 published on Wednesday, Apr 30, 2025 by tencentcloudstack
tencentcloud.getCkafkaDatahubGroupOffsets
Explore with Pulumi AI
tencentcloud 1.81.189 published on Wednesday, Apr 30, 2025 by tencentcloudstack
Use this data source to query detailed information of ckafka datahub_group_offsets
Example Usage
import * as pulumi from "@pulumi/pulumi";
import * as tencentcloud from "@pulumi/tencentcloud";
const datahubGroupOffsets = tencentcloud.getCkafkaDatahubGroupOffsets({});
import pulumi
import pulumi_tencentcloud as tencentcloud
datahub_group_offsets = tencentcloud.get_ckafka_datahub_group_offsets()
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.GetCkafkaDatahubGroupOffsets(ctx, &tencentcloud.GetCkafkaDatahubGroupOffsetsArgs{}, nil)
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 datahubGroupOffsets = Tencentcloud.GetCkafkaDatahubGroupOffsets.Invoke();
});
package generated_program;
import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.tencentcloud.TencentcloudFunctions;
import com.pulumi.tencentcloud.inputs.GetCkafkaDatahubGroupOffsetsArgs;
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 datahubGroupOffsets = TencentcloudFunctions.getCkafkaDatahubGroupOffsets();
}
}
variables:
datahubGroupOffsets:
fn::invoke:
function: tencentcloud:getCkafkaDatahubGroupOffsets
arguments: {}
Using getCkafkaDatahubGroupOffsets
Two invocation forms are available. The direct form accepts plain arguments and either blocks until the result value is available, or returns a Promise-wrapped result. The output form accepts Input-wrapped arguments and returns an Output-wrapped result.
function getCkafkaDatahubGroupOffsets(args: GetCkafkaDatahubGroupOffsetsArgs, opts?: InvokeOptions): Promise<GetCkafkaDatahubGroupOffsetsResult>
function getCkafkaDatahubGroupOffsetsOutput(args: GetCkafkaDatahubGroupOffsetsOutputArgs, opts?: InvokeOptions): Output<GetCkafkaDatahubGroupOffsetsResult>
def get_ckafka_datahub_group_offsets(group: Optional[str] = None,
id: Optional[str] = None,
name: Optional[str] = None,
result_output_file: Optional[str] = None,
search_word: Optional[str] = None,
opts: Optional[InvokeOptions] = None) -> GetCkafkaDatahubGroupOffsetsResult
def get_ckafka_datahub_group_offsets_output(group: Optional[pulumi.Input[str]] = None,
id: Optional[pulumi.Input[str]] = None,
name: Optional[pulumi.Input[str]] = None,
result_output_file: Optional[pulumi.Input[str]] = None,
search_word: Optional[pulumi.Input[str]] = None,
opts: Optional[InvokeOptions] = None) -> Output[GetCkafkaDatahubGroupOffsetsResult]
func GetCkafkaDatahubGroupOffsets(ctx *Context, args *GetCkafkaDatahubGroupOffsetsArgs, opts ...InvokeOption) (*GetCkafkaDatahubGroupOffsetsResult, error)
func GetCkafkaDatahubGroupOffsetsOutput(ctx *Context, args *GetCkafkaDatahubGroupOffsetsOutputArgs, opts ...InvokeOption) GetCkafkaDatahubGroupOffsetsResultOutput
> Note: This function is named GetCkafkaDatahubGroupOffsets
in the Go SDK.
public static class GetCkafkaDatahubGroupOffsets
{
public static Task<GetCkafkaDatahubGroupOffsetsResult> InvokeAsync(GetCkafkaDatahubGroupOffsetsArgs args, InvokeOptions? opts = null)
public static Output<GetCkafkaDatahubGroupOffsetsResult> Invoke(GetCkafkaDatahubGroupOffsetsInvokeArgs args, InvokeOptions? opts = null)
}
public static CompletableFuture<GetCkafkaDatahubGroupOffsetsResult> getCkafkaDatahubGroupOffsets(GetCkafkaDatahubGroupOffsetsArgs args, InvokeOptions options)
public static Output<GetCkafkaDatahubGroupOffsetsResult> getCkafkaDatahubGroupOffsets(GetCkafkaDatahubGroupOffsetsArgs args, InvokeOptions options)
fn::invoke:
function: tencentcloud:index/getCkafkaDatahubGroupOffsets:getCkafkaDatahubGroupOffsets
arguments:
# arguments dictionary
The following arguments are supported:
- Group string
- Kafka consumer group.
- Name string
- topic name that the task subscribe.
- Id string
- Result
Output stringFile - Used to save results.
- Search
Word string - fuzzy match topicName.
- Group string
- Kafka consumer group.
- Name string
- topic name that the task subscribe.
- Id string
- Result
Output stringFile - Used to save results.
- Search
Word string - fuzzy match topicName.
- group String
- Kafka consumer group.
- name String
- topic name that the task subscribe.
- id String
- result
Output StringFile - Used to save results.
- search
Word String - fuzzy match topicName.
- group string
- Kafka consumer group.
- name string
- topic name that the task subscribe.
- id string
- result
Output stringFile - Used to save results.
- search
Word string - fuzzy match topicName.
- group str
- Kafka consumer group.
- name str
- topic name that the task subscribe.
- id str
- result_
output_ strfile - Used to save results.
- search_
word str - fuzzy match topicName.
- group String
- Kafka consumer group.
- name String
- topic name that the task subscribe.
- id String
- result
Output StringFile - Used to save results.
- search
Word String - fuzzy match topicName.
getCkafkaDatahubGroupOffsets Result
The following output properties are available:
- Group string
- Id string
- Name string
- Topic
Lists List<GetCkafka Datahub Group Offsets Topic List> - The topic array, where each element is a json object.
- Result
Output stringFile - Search
Word string
- Group string
- Id string
- Name string
- Topic
Lists []GetCkafka Datahub Group Offsets Topic List - The topic array, where each element is a json object.
- Result
Output stringFile - Search
Word string
- group String
- id String
- name String
- topic
Lists List<GetCkafka Datahub Group Offsets Topic List> - The topic array, where each element is a json object.
- result
Output StringFile - search
Word String
- group string
- id string
- name string
- topic
Lists GetCkafka Datahub Group Offsets Topic List[] - The topic array, where each element is a json object.
- result
Output stringFile - search
Word string
- group str
- id str
- name str
- topic_
lists Sequence[GetCkafka Datahub Group Offsets Topic List] - The topic array, where each element is a json object.
- result_
output_ strfile - search_
word str
- group String
- id String
- name String
- topic
Lists List<Property Map> - The topic array, where each element is a json object.
- result
Output StringFile - search
Word String
Supporting Types
GetCkafkaDatahubGroupOffsetsTopicList
- Partitions
List<Get
Ckafka Datahub Group Offsets Topic List Partition> - The topic partition array, where each element is a json object.
- Topic string
- topic name.
- Partitions
[]Get
Ckafka Datahub Group Offsets Topic List Partition - The topic partition array, where each element is a json object.
- Topic string
- topic name.
- partitions
List<Get
Ckafka Datahub Group Offsets Topic List Partition> - The topic partition array, where each element is a json object.
- topic String
- topic name.
- partitions
Get
Ckafka Datahub Group Offsets Topic List Partition[] - The topic partition array, where each element is a json object.
- topic string
- topic name.
- partitions
Sequence[Get
Ckafka Datahub Group Offsets Topic List Partition] - The topic partition array, where each element is a json object.
- topic str
- topic name.
- partitions List<Property Map>
- The topic partition array, where each element is a json object.
- topic String
- topic name.
GetCkafkaDatahubGroupOffsetsTopicListPartition
- error_
code float - Error Code.
- lag float
- The number of unconsumed messages.
- log_
end_ floatoffset - partition Log End Offset.
- metadata str
- Usually an empty string.
- offset float
- consumer offset.
- partition float
- topic partitionId.
Package Details
- Repository
- tencentcloud tencentcloudstack/terraform-provider-tencentcloud
- License
- Notes
- This Pulumi package is based on the
tencentcloud
Terraform Provider.
tencentcloud 1.81.189 published on Wednesday, Apr 30, 2025 by tencentcloudstack