ConsumerChannel

package generated_program;
import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.alicloud.AlicloudFunctions;
import com.pulumi.alicloud.inputs.GetZonesArgs;
import com.pulumi.alicloud.vpc.VpcFunctions;
import com.pulumi.alicloud.vpc.inputs.GetNetworksArgs;
import com.pulumi.alicloud.vpc.inputs.GetSwitchesArgs;
import com.pulumi.alicloud.rds.Instance;
import com.pulumi.alicloud.rds.InstanceArgs;
import com.pulumi.alicloud.rds.Database;
import com.pulumi.alicloud.rds.DatabaseArgs;
import com.pulumi.alicloud.rds.Account;
import com.pulumi.alicloud.rds.AccountArgs;
import com.pulumi.alicloud.rds.AccountPrivilege;
import com.pulumi.alicloud.rds.AccountPrivilegeArgs;
import com.pulumi.alicloud.dts.SubscriptionJob;
import com.pulumi.alicloud.dts.SubscriptionJobArgs;
import com.pulumi.alicloud.dts.ConsumerChannel;
import com.pulumi.alicloud.dts.ConsumerChannelArgs;
import com.pulumi.codegen.internal.KeyedValue;
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 name = config.get("name").orElse("tftestdts");
        final var creation = config.get("creation").orElse("Rds");
        final var defaultZones = AlicloudFunctions.getZones(GetZonesArgs.builder()
            .availableResourceCreation(creation)
            .build());
        final var defaultNetworks = VpcFunctions.getNetworks(GetNetworksArgs.builder()
            .nameRegex("default-NODELETING")
            .build());
        final var defaultSwitches = VpcFunctions.getSwitches(GetSwitchesArgs.builder()
            .vpcId(defaultNetworks.applyValue(getNetworksResult -> getNetworksResult.ids()[0]))
            .zoneId(defaultZones.applyValue(getZonesResult -> getZonesResult.zones()[0].id()))
            .build());
        var instance = new Instance("instance", InstanceArgs.builder()
            .engine("MySQL")
            .engineVersion("5.6")
            .instanceType("rds.mysql.s1.small")
            .instanceStorage("10")
            .vswitchId(defaultSwitches.applyValue(getSwitchesResult -> getSwitchesResult.ids()[0]))
            .instanceName(name)
            .build());
        for (var i = 0; i < 2; i++) {
            new Database("db-" + i, DatabaseArgs.builder()
                .instanceId(instance.id())
                .description("from terraform")
                .build());
}
        var account = new Account("account", AccountArgs.builder()
            .dbInstanceId(instance.id())
            .accountName("tftestprivilege")
            .accountPassword("Test12345")
            .accountDescription("from terraform")
            .build());
        var privilege = new AccountPrivilege("privilege", AccountPrivilegeArgs.builder()
            .instanceId(instance.id())
            .accountName(account.name())
            .privilege("ReadWrite")
            .dbNames(db.stream().map(element -> element.name()).collect(toList()))
            .build());
        var defaultSubscriptionJob = new SubscriptionJob("defaultSubscriptionJob", SubscriptionJobArgs.builder()
            .dtsJobName(name)
            .paymentType("PayAsYouGo")
            .sourceEndpointEngineName("MySQL")
            .sourceEndpointRegion("cn-hangzhou")
            .sourceEndpointInstanceType("RDS")
            .sourceEndpointInstanceId(instance.id())
            .sourceEndpointDatabaseName("tfaccountpri_0")
            .sourceEndpointUserName("tftestprivilege")
            .sourceEndpointPassword("Test12345")
            .subscriptionInstanceNetworkType("vpc")
            .dbList("""
        {"dtstestdata": {"name": "tfaccountpri_0", "all": true}}
            """)
            .subscriptionInstanceVpcId(defaultNetworks.applyValue(getNetworksResult -> getNetworksResult.ids()[0]))
            .subscriptionInstanceVswitchId(defaultSwitches.applyValue(getSwitchesResult -> getSwitchesResult.ids()[0]))
            .status("Normal")
            .build());
        var defaultConsumerChannel = new ConsumerChannel("defaultConsumerChannel", ConsumerChannelArgs.builder()
            .dtsInstanceId(defaultSubscriptionJob.dtsInstanceId())
            .consumerGroupName(name)
            .consumerGroupUserName(name)
            .consumerGroupPassword("tftestAcc123")
            .build());
    }
}

$ pulumi import alicloud:dts/consumerChannel:ConsumerChannel example <dts_instance_id>:<consumer_group_id>