资源编排服务ROS(Resource Orchestration Service)支持通过创建资源栈的方式安装Kafka单机版。
背景信息
Apache Kafka是一个开源流处理平台,使用Scala和Java语言编写。Kafka作为一种高吞吐量的分布式发布订阅消息系统,可以处理消费者模式网站中的所有动作流数据。
模板示例Kafka 单机版(已有VPC)在已有专有网络、交换机和安全组等资源的基础上,创建一台ECS实例并绑定弹性公网IP(EIP)。
模板示例中使用的软件版本。
Java JDK(Java Development Kit):1.8.0
Scala(编程语言):2.12
Kafka(计算引擎):0.10.2.2
Kafka数据存储在数据盘中默认路径为:
/home/software/
,默认Kafka bin目录路径为:/home/software/kafka/bin
。创建资源栈成功后即可获取KafkaManagerUrl,登录Kafka管理控制台。
如需通过外网访问KafkaManagerUrl,请在安全组添加入方向9000访问规则。具体操作,请参见添加安全组规则。
步骤一:创建资源栈
登录资源编排控制台。
在左侧导航栏,选择
。查找模板Kafka单机版(已有VPC)。
单击创建资源栈。
在配置参数页面,输入资源栈名称,并设置以下参数。
参数
说明
示例
交换机可用区
专有网络下的交换机可用区ID。
华北1可用区C
现有VPC的实例ID
VPC实例ID。
关于如何创建和查询VPC实例,请参见创建和管理专有网络。
vpc-bp1m6fww66xbntjyc****
网络交换机ID
专有网络下的交换机ID。
关于如何创建和查询交换机,请参见创建和管理交换机。
vsw-bp183p93qs667muql****
业务安全组ID
ECS安全组ID。
关于如何查询安全组ID,请参见查询安全组。
sg-bp15ed6xe1yxeycg7o****
实例规格
ECS实例规格。
请选用有效的实例规格。更多信息,请参见实例规格族。
ecs.c5.large
镜像ID
ECS镜像ID。
更多信息,请参见:查找镜像。
centos_7
实例密码
ECS实例密码。
Test_12****
公网IP带宽值
公网IP带宽。
单位:Mbps。
取值范围:1~100。
5
磁盘类型
取值:
cloud_efficiency:高效云盘。
cloud_ssd:SSD云盘。
cloud_essd:ESSD云盘。
cloud:普通云盘。
ephemeral_ssd:本地SSD盘。
更多信息,请参见云盘概述。
cloud_efficiency
数据盘空间
实例数据盘大小。
取值范围:20~32,786
单位:GB
20
Kafka监听端口
请使用1000以上的端口号。
默认值:9092
9092
消息保留时间
消息最长保留时间。
默认值:24
单位:小时
24
Topic规格
Topic数量。
默认值:50
50
单击创建。
在资源栈信息页签查看资源栈状态。资源栈创建成功后,单击输出,获取
KafkaManagerUrl
。访问
KafkaManagerUrl
,登录Kafka管理控制台。
步骤二:查看资源
在左侧导航栏,单击资源栈。
在资源栈列表页面,单击目标资源栈名称。
单击资源页签,查看资源信息。
本示例中,资源信息如下表所示。
资源
数量
资源说明
规格说明
ALIYUN::ECS::Instance
1
创建一台云服务器,用于安装Kafka单机版。
总数量:1台。
实例规格:ecs.c5.large。
磁盘类别:高效云盘。
系统盘空间:40GB。
分配公网IP:是。
说明资源收费情况,请参见官网报价或各产品定价文档。