資源編排服務ROS(Resource Orchestration Service)支持通過創建資源棧的方式安裝Kafka集群版。
背景信息
Apache Kafka是一個開源流處理平臺,使用Scala和Java語言編寫。Kafka作為一種高吞吐量的分布式發布訂閱消息系統,可以處理消費者模式網站中的所有動作流數據。
模板示例Kafka 集群版-已有專有網絡VPC在已有專有網絡、交換機和安全組等資源的基礎上,創建多臺ECS實例。其中一臺ECS實例綁定彈性公網IP(EIP)作為管理節點,其他ECS實例使用彈性伸縮進行管理。模板示例中使用的軟件版本如下:
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)。
單擊創建資源棧。
在配置參數頁面,輸入資源棧名稱,并設置以下參數。
參數
說明
示例
現有VPC的實例ID
VPC實例ID。
關于如何創建和查詢VPC實例,請參見創建和管理專有網絡。
vpc-bp1m6fww66xbntjyc****
交換機可用區
專有網絡下的交換機可用區ID。
華北1可用區C
網絡交換機ID
專有網絡下的交換機ID。
關于如何創建和查詢交換機,請參見創建和管理交換機。
vsw-bp183p93qs667muql****
業務安全組ID
ECS安全組ID。
關于如何查詢安全組ID,請參見查詢安全組。
sg-bp15ed6xe1yxeycg7o****
實例規格
ECS實例規格。
請選用有效的實例規格。更多信息,請參見實例規格族。
ecs.c5.large
實例密碼
ECS實例密碼。
Test_12****
公網IP帶寬值
公網IP帶寬。
單位:Mbps
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
實例數量
Kafka集群數量。
取值范圍:3~10
3
單擊創建。
在資源棧信息頁簽查看資源棧狀態。資源棧創建成功后,單擊輸出,獲取KafkaManagerUrl。
訪問KafkaManagerUrl,登錄Kafka管理控制臺。
步驟二:查看資源
在左側導航欄,單擊資源棧。
在資源棧列表頁面,單擊目標資源棧名稱。
單擊資源頁簽,查看資源信息。
本示例中,資源信息如下表所示。
資源
數量
資源說明
規格說明
ALIYUN::ECS::InstanceGroup
1
創建一臺云服務器,用于安裝Kafka Master服務。
總數量:1臺。
實例規格:ecs.c5.large。
磁盤類別:高效云盤。
系統盤空間:40GB。
分配公網IP:是。
ALIYUN::ESS::ScalingGroup
2
創建兩個彈性伸縮組,用于安裝Kafka Slave服務。
彈性伸縮組會根據您設置的伸縮規則自動為您調整彈性計算資源大小,以滿足您業務需求的變化。
總數量:2臺。
實例規格:ecs.c5.large。
磁盤類別:高效云盤。
系統盤空間:40GB。
分配公網IP:是。
ALIYUN::RAM::Role
1
創建一個RAM角色,用于頒發短時有效的訪問令牌(STS令牌),使其成為一種更安全的授予訪問權限的方法。
無
ALIYUN::VPC::EIP
1
創建一個彈性公網IP,用于綁定ECS實例,以便通過外網訪問ECS實例。
無
ALIYUN::OOS::Template
1
創建一個OOS模板,用于創建生命周期掛鉤。
關于生命周期掛鉤的更多信息,請參見生命周期掛鉤。
無
說明資源收費情況,請參見官網報價或各產品定價文檔。