安装 Kafka 集群版

架构图

              生产者（Producer）           消费者（Consumer）
                    ↓                            ↑
         ┌──────────────────────────────────────────┐
         │            Kafka 集群                     │
         │                                          │
         │  Master ECS ← EIP（Kafka Manager:9000）   │
         │    Broker-0（Kafka:9092 + ZooKeeper）     │
         │                                          │
         │  Worker ECS × N（弹性伸缩组管理）          │
         │    Broker-1（Kafka:9092 + ZooKeeper）     │
         │    Broker-2（Kafka:9092 + ZooKeeper）     │
         │    ...                                   │
         └──────────────────────────────────────────┘
                          │
                   各节点数据盘 /home/software/
                   （消息持久化存储）

网络与 ECS 参数

Kafka 专属参数

方式一：通过 ROS 公共模板部署（推荐）

1. 登录资源编排控制台。

2. 在左侧导航栏，选择模板 > 公共模板

3. 在解决方案模板页签的搜索框中输入 Kafka，找到模板Kafka 集群版（已有VPC）。

4. 单击创建资源栈。

5. 在配置参数页面，输入资源栈名称，并按部署参数说明填写各项参数。

6. 单击下一步：检查并确认，然后单击创建。

7. 在左侧导航栏，选择部署 > 资源栈，在资源栈列表页面单击目标资源栈ID，在资源栈信息页签查看资源栈状态，等待状态变为CREATE_COMPLETE

8. 单击输出页签，获取 KafkaManagerUrl。使用浏览器访问该地址，登录 Kafka 管理控制台即部署成功。

方式二：通过 ROS IaC Code 部署

IaC Code 是面向云基础设施的 AI 基础设施即代码助手，可根据自然语言描述生成 ROS 模板并部署，使用方式参见IaC Code快速入门。

帮我在已有VPC中部署Kafka分布式消息集群。
要求：
1. 使用已有的VPC、VSwitch和安全组（不新建网络资源）。
2. 创建1台Master ECS节点，绑定弹性公网IP，运行Kafka Manager。
3. 创建弹性伸缩组管理Broker节点，初始2台Broker。
4. 所有节点使用CentOS 7镜像，挂载数据盘存储Kafka消息。
5. 通过UserData脚本自动安装JDK 1.8、Scala 2.12、Kafka 0.10.2.2。
6. 各节点内置ZooKeeper，Master和Broker自动完成集群组网。
7. 使用OOS模板创建生命周期挂钩，Broker扩容时自动安装Kafka并加入集群。
8. 安全组开放入方向9000端口（Kafka Manager）和9092端口（Kafka Broker）。
9. 资源栈输出KafkaManagerUrl。

验证Kafka集群

1. 在资源栈详情页单击输出，获取 KafkaManagerUrl。

2. 使用浏览器访问该地址，看到 Kafka Manager 管理界面即部署成功。

3. 在Kafka Manager中确认Broker节点数量是否与设置的"实例数量"一致