This topic describes how to deploy a Kafka cluster by creating a stack in the Resource Orchestration Service (ROS) console.

Background information

Apache Kafka is an open source stream processing platform that is written in Scala and Java. Apache Kafka is a high-throughput distributed publish-subscribe messaging system for processing streaming data of customer behaviors on websites.

The Deploy a Kafka Cluster in an Existing VPC sample template creates multiple Elastic Compute Service (ECS) instances based on existing resources such as a virtual private cloud (VPC), a vSwitch, and a security group. One of the created ECS instances is associated with an elastic IP address (EIP) to serve as a management node. Other ECS instances are managed by using Auto Scaling. The following software versions are used in the sample template:

  • JDK: 1.8.0
  • Scala: 2.12
  • Kafka: 0.10.2.2

The Kafka data for the sample template is stored in the data disk. The default storage directory of the Kafka data is /home/software/. The default storage directory of Kafka binaries is /home/software/kafka/bin.

After a stack is created by using the sample template, you can obtain the Kafka Manager URL and log on to the Kafka management console. To access the Kafka Manager URL over the Internet, add inbound rules to the security group to allow traffic on port 9000. For more information, see Add a security group rule.

Step 1: Create a stack

  1. Log on to the ROS console.
  2. In the left-side navigation pane, click Solution Center.
  3. Find the Deploy a Kafka Cluster in an Existing VPC template.
  4. Click Create Stack.
  5. In the Configure Template Parameters step, set Stack Name and the following parameters.
    ParameterDescriptionExample
    Existing VPC Instance IDThe ID of the VPC.

    For more information about how to create and query a VPC, see Create and manage a VPC.

    		vpc-bp1m6fww66xbntjyc****
    VSwitch Zone IDThe zone ID of the vSwitch in the VPC. Qingdao Zone C
    VSwitch IDThe ID of the vSwitch in the VPC.

    For more information about how to create and query a vSwitch, see Create and manage a vSwitch.

    		vsw-bp183p93qs667muql****
    Business Security Group IDThe ID of the ECS security group.

    For more information about how to query security groups, see Query security groups.

    		sg-bp15ed6xe1yxeycg7o****
    Instance TypeThe instance type of the ECS instance.

    Select a valid instance type. For more information, see Overview of instance families.

    		ecs.c5.large
    Instance PasswordThe password that is used to log on to the ECS instance. Test_12****
    Public IP BandwidthThe public IP bandwidth.

    Unit: Mbit/s.

    		5
    Disk TypeThe disk category of the ECS instance. Valid values:
    • cloud_efficiency: ultra disk
    • cloud_ssd: standard SSD
    • cloud_essd: enhanced SSD (ESSD)
    • cloud: basic disk
    • ephemeral_ssd: local SSD

    For more information, see Disks.

    		cloud_efficiency
    Data Disk SpaceThe data disk size of the ECS instance.

    Valid values: 20 to 32786.

    Unit: GB.

    		20
    Kafka Listeners PortThe Kafka listener port. The port number must be greater than 1000.

    Default value: 9092.

    		9092
    Message Retention TimeThe maximum period of time that a message can be retained.

    Default value: 24.

    Unit: hours.

    		24
    Topic SpecificationsThe number of topics.

    Default value: 50.

    		50
    Instance AmountThe number of ECS instances in the Kafka cluster.

    Valid values: 3 to 10.

    		3
  6. Click Create.
  7. View the stack status on the Stack Information tab of the stack management page. After the stack is created, click the Outputs tab to view the Kafka Manager URL.
  8. Use the URL to log on to the Kafka management console.

Step 2: View resources

  1. Log on to the ROS console.
  2. In the left-side navigation pane, click Stacks.
  3. On the Stacks page, click the stack that you created.
  4. On the stack management page, click the Resources tab to view the resource list.
    The following table describes the resources in this example.
    Resource typeQuantityDescriptionSpecifications
    ALIYUN::ECS::InstanceGroup1Creates an ECS instance to deploy the Kafka primary service. A single instance of the following specifications is created:
    • InstanceType: ecs.c5.large
    • SystemDiskCategory: cloud_efficiency
    • SystemDiskSize: 40
    • AllocatePublicIP: true
    ALIYUN::ESS::ScalingGroup2Creates two scaling groups to deploy the Kafka secondary service.

    Scaling groups scale computing resources based on the scaling rules that you set to meet your business requirements.

    		Two instances of the following specifications are created:
    • InstanceType: ecs.c5.large
    • SystemDiskCategory: cloud_efficiency
    • SystemDiskSize: 40
    • AllocatePublicIP: true
    ALIYUN::RAM::Role1Creates a Resource Access Management (RAM) role to issue a Security Token Service (STS) token that is valid within a temporary period. This is a more secure method to grant access permissions. None
    ALIYUN::VPC::EIP1Creates an EIP to associate the EIP with an ECS instance. This way, the instance can be accessed over the Internet. None
    ALIYUN::OOS::Template1Creates an Operation Orchestration Service (OSS) template to create lifecycle hooks.

    For more information about lifecycle hooks, see Lifecycle hooks.

    		None
    Note For more information about the resource charges, see the pricing schedule on the official website or the product pricing documentation.