getConsumerGroups

This data source provides a list of ALIKAFKA Consumer Groups in an Alibaba Cloud account according to the specified filters.

NOTE: Available in 1.56.0+

Example Usage

import * as pulumi from "@pulumi/pulumi";
import * as alicloud from "@pulumi/alicloud";
const consumerGroupsDs = alicloud.actiontrail.getConsumerGroups({
instanceId: "xxx",
consumerIdRegex: "CID-alikafkaGroupDatasourceName",
outputFile: "consumerGroups.txt",
});
export const firstGroupName = consumerGroupsDs.then(consumerGroupsDs => consumerGroupsDs.consumerIds?.[0]);
import pulumi
import pulumi_alicloud as alicloud
consumer_groups_ds = alicloud.actiontrail.get_consumer_groups(instance_id="xxx",
consumer_id_regex="CID-alikafkaGroupDatasourceName",
output_file="consumerGroups.txt")
pulumi.export("firstGroupName", consumer_groups_ds.consumer_ids[0])
using System.Collections.Generic;
using System.Linq;
using Pulumi;
using AliCloud = Pulumi.AliCloud;
return await Deployment.RunAsync(() =>
{
var consumerGroupsDs = AliCloud.ActionTrail.GetConsumerGroups.Invoke(new()
{
InstanceId = "xxx",
ConsumerIdRegex = "CID-alikafkaGroupDatasourceName",
OutputFile = "consumerGroups.txt",
});
return new Dictionary<string, object?>
{
["firstGroupName"] = consumerGroupsDs&#46;Apply(getConsumerGroupsResult => getConsumerGroupsResult&#46;ConsumerIds[0]),
};
});
package main
import (
"github.com/pulumi/pulumi-alicloud/sdk/v3/go/alicloud/actiontrail"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)
func main() {
pulumi.Run(func(ctx *pulumi.Context) error {
consumerGroupsDs, err := actiontrail.GetConsumerGroups(ctx, &actiontrail.GetConsumerGroupsArgs{
InstanceId: "xxx",
ConsumerIdRegex: pulumi.StringRef("CID-alikafkaGroupDatasourceName"),
OutputFile: pulumi.StringRef("consumerGroups.txt"),
}, nil)
if err != nil {
return err
}
ctx.Export("firstGroupName", consumerGroupsDs.ConsumerIds[0])
return nil
})
}
package generated_program;
import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.alicloud.actiontrail.ActiontrailFunctions;
import com.pulumi.alicloud.actiontrail.inputs.GetConsumerGroupsArgs;
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 consumerGroupsDs = ActiontrailFunctions.getConsumerGroups(GetConsumerGroupsArgs.builder()
.instanceId("xxx")
.consumerIdRegex("CID-alikafkaGroupDatasourceName")
.outputFile("consumerGroups.txt")
.build());
ctx.export("firstGroupName", consumerGroupsDs.consumerIds()[0]);
}
}
variables:
consumerGroupsDs:
fn::invoke:
function: alicloud:actiontrail:getConsumerGroups
arguments:
instanceId: xxx
consumerIdRegex: CID-alikafkaGroupDatasourceName
outputFile: consumerGroups.txt
outputs:
firstGroupName: ${consumerGroupsDs.consumerIds[0]}

Return

A collection of values returned by getConsumerGroups.

Parameters

argument

A collection of arguments for invoking getConsumerGroups.


suspend fun getConsumerGroups(consumerIdRegex: String? = null, ids: List<String>? = null, instanceId: String, outputFile: String? = null): GetConsumerGroupsResult

Return

A collection of values returned by getConsumerGroups.

Parameters

consumerIdRegex

A regex string to filter results by the consumer group id.

ids

A list of ALIKAFKA Consumer Groups IDs, It is formatted to <instance_id>:<consumer_id>.

instanceId

ID of the ALIKAFKA Instance that owns the consumer groups.

outputFile

File name where to save data source results (after running pulumi preview).

See also


Return

A collection of values returned by getConsumerGroups.

Parameters

argument

Builder for com.pulumi.alicloud.actiontrail.kotlin.inputs.GetConsumerGroupsPlainArgs.

See also