Namespace Pulumi.AliCloud.AliKafka

Classes

ConsumerGroup

Provides an ALIKAFKA consumer group resource.

NOTE: Available in 1.56.0+

NOTE: Only the following regions support create alikafka consumer group. [cn-hangzhou,cn-beijing,cn-shenzhen,cn-shanghai,cn-qingdao,cn-hongkong,cn-huhehaote,cn-zhangjiakou,ap-southeast-1,ap-south-1,ap-southeast-5]

Example Usage

using Pulumi;
using AliCloud = Pulumi.AliCloud;

class MyStack : Stack
{
public MyStack()
{
    var config = new Config();
    var consumerId = config.Get("consumerId") ?? "CID-alikafkaGroupDatasourceName";
    var defaultZones = Output.Create(AliCloud.GetZones.InvokeAsync(new AliCloud.GetZonesArgs
    {
        AvailableResourceCreation = "VSwitch",
    }));
    var defaultNetwork = new AliCloud.Vpc.Network("defaultNetwork", new AliCloud.Vpc.NetworkArgs
    {
        CidrBlock = "172.16.0.0/12",
    });
    var defaultSwitch = new AliCloud.Vpc.Switch("defaultSwitch", new AliCloud.Vpc.SwitchArgs
    {
        AvailabilityZone = defaultZones.Apply(defaultZones => defaultZones.Zones[0].Id),
        CidrBlock = "172.16.0.0/24",
        VpcId = defaultNetwork.Id,
    });
    var defaultInstance = new AliCloud.AliKafka.Instance("defaultInstance", new AliCloud.AliKafka.InstanceArgs
    {
        DeployType = "5",
        DiskSize = "500",
        DiskType = "1",
        IoMax = "20",
        TopicQuota = "50",
        VswitchId = defaultSwitch.Id,
    });
    var defaultConsumerGroup = new AliCloud.AliKafka.ConsumerGroup("defaultConsumerGroup", new AliCloud.AliKafka.ConsumerGroupArgs
    {
        ConsumerId = consumerId,
        InstanceId = defaultInstance.Id,
    });
}

}

ConsumerGroupArgs

ConsumerGroupState

Instance

Provides an ALIKAFKA instance resource.

NOTE: Available in 1.59.0+

NOTE: ALIKAFKA instance resource only support create post pay instance. Creation or modification may took about 10-40 minutes.

NOTE: Only the following regions support create alikafka pre paid instance. [cn-hangzhou,cn-beijing,cn-shenzhen,cn-shanghai,cn-qingdao,cn-hongkong,cn-huhehaote,cn-zhangjiakou,ap-southeast-1,ap-south-1,ap-southeast-5]

NOTE: Only the following regions support create alikafka post paid instance. [cn-hangzhou,cn-beijing,cn-shenzhen,cn-shanghai,cn-qingdao,cn-hongkong,cn-huhehaote,cn-zhangjiakou,ap-southeast-1]

Example Usage

using Pulumi;
using AliCloud = Pulumi.AliCloud;

class MyStack : Stack
{
public MyStack()
{
    var config = new Config();
    var instanceName = config.Get("instanceName") ?? "alikafkaInstanceName";
    var defaultZones = Output.Create(AliCloud.GetZones.InvokeAsync(new AliCloud.GetZonesArgs
    {
        AvailableResourceCreation = "VSwitch",
    }));
    var defaultNetwork = new AliCloud.Vpc.Network("defaultNetwork", new AliCloud.Vpc.NetworkArgs
    {
        CidrBlock = "172.16.0.0/12",
    });
    var defaultSwitch = new AliCloud.Vpc.Switch("defaultSwitch", new AliCloud.Vpc.SwitchArgs
    {
        AvailabilityZone = defaultZones.Apply(defaultZones => defaultZones.Zones[0].Id),
        CidrBlock = "172.16.0.0/24",
        VpcId = defaultNetwork.Id,
    });
    var defaultInstance = new AliCloud.AliKafka.Instance("defaultInstance", new AliCloud.AliKafka.InstanceArgs
    {
        DeployType = "4",
        DiskSize = "500",
        DiskType = "1",
        IoMax = "20",
        TopicQuota = "50",
        VswitchId = defaultSwitch.Id,
    });
}

}

InstanceArgs

InstanceState

SaslAcl

Provides an ALIKAFKA sasl acl resource.

NOTE: Available in 1.66.0+

NOTE: Only the following regions support create alikafka sasl user. [cn-hangzhou,cn-beijing,cn-shenzhen,cn-shanghai,cn-qingdao,cn-hongkong,cn-huhehaote,cn-zhangjiakou,ap-southeast-1,ap-south-1,ap-southeast-5]

Example Usage

using Pulumi;
using AliCloud = Pulumi.AliCloud;

class MyStack : Stack
{
public MyStack()
{
    var config = new Config();
    var username = config.Get("username") ?? "testusername";
    var password = config.Get("password") ?? "testpassword";
    var defaultZones = Output.Create(AliCloud.GetZones.InvokeAsync(new AliCloud.GetZonesArgs
    {
        AvailableResourceCreation = "VSwitch",
    }));
    var defaultNetwork = new AliCloud.Vpc.Network("defaultNetwork", new AliCloud.Vpc.NetworkArgs
    {
        CidrBlock = "172.16.0.0/12",
    });
    var defaultSwitch = new AliCloud.Vpc.Switch("defaultSwitch", new AliCloud.Vpc.SwitchArgs
    {
        AvailabilityZone = defaultZones.Apply(defaultZones => defaultZones.Zones[0].Id),
        CidrBlock = "172.16.0.0/24",
        VpcId = defaultNetwork.Id,
    });
    var defaultInstance = new AliCloud.AliKafka.Instance("defaultInstance", new AliCloud.AliKafka.InstanceArgs
    {
        DeployType = "5",
        DiskSize = "500",
        DiskType = "1",
        IoMax = "20",
        TopicQuota = "50",
        VswitchId = defaultSwitch.Id,
    });
    var defaultTopic = new AliCloud.AliKafka.Topic("defaultTopic", new AliCloud.AliKafka.TopicArgs
    {
        InstanceId = defaultInstance.Id,
        Remark = "topic-remark",
        Topic = "test-topic",
    });
    var defaultSaslUser = new AliCloud.AliKafka.SaslUser("defaultSaslUser", new AliCloud.AliKafka.SaslUserArgs
    {
        InstanceId = defaultInstance.Id,
        Password = password,
        Username = username,
    });
    var defaultSaslAcl = new AliCloud.AliKafka.SaslAcl("defaultSaslAcl", new AliCloud.AliKafka.SaslAclArgs
    {
        AclOperationType = "Write",
        AclResourceName = defaultTopic.TopicName,
        AclResourcePatternType = "LITERAL",
        AclResourceType = "Topic",
        InstanceId = defaultInstance.Id,
        Username = defaultSaslUser.Username,
    });
}

}

SaslAclArgs

SaslAclState

SaslUser

Provides an ALIKAFKA sasl user resource.

NOTE: Available in 1.66.0+

NOTE: Only the following regions support create alikafka sasl user. [cn-hangzhou,cn-beijing,cn-shenzhen,cn-shanghai,cn-qingdao,cn-hongkong,cn-huhehaote,cn-zhangjiakou,ap-southeast-1,ap-south-1,ap-southeast-5]

Example Usage

using Pulumi;
using AliCloud = Pulumi.AliCloud;

class MyStack : Stack
{
public MyStack()
{
    var config = new Config();
    var username = config.Get("username") ?? "testusername";
    var password = config.Get("password") ?? "testpassword";
    var defaultZones = Output.Create(AliCloud.GetZones.InvokeAsync(new AliCloud.GetZonesArgs
    {
        AvailableResourceCreation = "VSwitch",
    }));
    var defaultNetwork = new AliCloud.Vpc.Network("defaultNetwork", new AliCloud.Vpc.NetworkArgs
    {
        CidrBlock = "172.16.0.0/12",
    });
    var defaultSwitch = new AliCloud.Vpc.Switch("defaultSwitch", new AliCloud.Vpc.SwitchArgs
    {
        AvailabilityZone = defaultZones.Apply(defaultZones => defaultZones.Zones[0].Id),
        CidrBlock = "172.16.0.0/24",
        VpcId = defaultNetwork.Id,
    });
    var defaultInstance = new AliCloud.AliKafka.Instance("defaultInstance", new AliCloud.AliKafka.InstanceArgs
    {
        DeployType = "5",
        DiskSize = "500",
        DiskType = "1",
        IoMax = "20",
        TopicQuota = "50",
        VswitchId = defaultSwitch.Id,
    });
    var defaultSaslUser = new AliCloud.AliKafka.SaslUser("defaultSaslUser", new AliCloud.AliKafka.SaslUserArgs
    {
        InstanceId = defaultInstance.Id,
        Password = password,
        Username = username,
    });
}

}

SaslUserArgs

SaslUserState

Topic

Provides an ALIKAFKA topic resource.

NOTE: Available in 1.56.0+

NOTE: Only the following regions support create alikafka topic. [cn-hangzhou,cn-beijing,cn-shenzhen,cn-shanghai,cn-qingdao,cn-hongkong,cn-huhehaote,cn-zhangjiakou,ap-southeast-1,ap-south-1,ap-southeast-5]

Example Usage

using Pulumi;
using AliCloud = Pulumi.AliCloud;

class MyStack : Stack
{
public MyStack()
{
    var defaultZones = Output.Create(AliCloud.GetZones.InvokeAsync(new AliCloud.GetZonesArgs
    {
        AvailableResourceCreation = "VSwitch",
    }));
    var defaultNetwork = new AliCloud.Vpc.Network("defaultNetwork", new AliCloud.Vpc.NetworkArgs
    {
        CidrBlock = "172.16.0.0/12",
    });
    var defaultSwitch = new AliCloud.Vpc.Switch("defaultSwitch", new AliCloud.Vpc.SwitchArgs
    {
        AvailabilityZone = defaultZones.Apply(defaultZones => defaultZones.Zones[0].Id),
        CidrBlock = "172.16.0.0/24",
        VpcId = defaultNetwork.Id,
    });
    var defaultInstance = new AliCloud.AliKafka.Instance("defaultInstance", new AliCloud.AliKafka.InstanceArgs
    {
        DeployType = "5",
        DiskSize = "500",
        DiskType = "1",
        IoMax = "20",
        TopicQuota = "50",
        VswitchId = defaultSwitch.Id,
    });
    var config = new Config();
    var topic = config.Get("topic") ?? "alikafkaTopicName";
    var defaultTopic = new AliCloud.AliKafka.Topic("defaultTopic", new AliCloud.AliKafka.TopicArgs
    {
        CompactTopic = "false",
        InstanceId = defaultInstance.Id,
        LocalTopic = "false",
        PartitionNum = "12",
        Remark = "dafault_kafka_topic_remark",
        Topic = topic,
    });
}

}

TopicArgs

TopicState