检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
然后启动Kafka三个节点实例（即broker实例）进行服务的提供，同时启动一个KafkaManager用作可视化管理。整体结构如下： 安装Kubebuilder 构建Operator 实现Operator 父主题： 如何从零开始开发Operator
us_javaagent/0.15.0/jmx_prometheus_javaagent-0.15.0.jar。 创建配置文件 创建初始化ZooKeeper的配置启动参数脚本zkGenConfig.sh。 #!/bin/bash ZK_CONF_DIR=${ZK_CONF_DIR:-"/opt/kafka_2
raw 存放兼容的第三方文件，如Helm/Operator-Framework。 否 生命周期文件 lifecycle.yaml 存放服务包的安装部署、升级等生命周期相关信息。 是 服务包约束 命名规则：只允许包含大小写字母、数字、下划线、中划线及点，且不能以下划线、中划线及点结尾。{
// Hwfka 镜像地址 Storage *StorageSpec `json:"storage"` // Hwfka 数据存储相关配置 } type StorageSpec struct { Class string
状态属性。 参数 size：应用实例包含的实例数量。 image：应用的容器镜像地址。 storage：应用数据存储相关配置。 状态 phase：应用实例安装状态。 server：应用访问地址。 以创建一个Kafka应用，指定其Pod数量为3为例，设计CR如下： apiVersion:
storageClassName: local-pv-immediate volumeMode: Filesystem 使用华为云存储，需要CCE集群中预先安装everest插件。 上述资源可通过Go语言在Reconcile协调逻辑中实现，具体请参见Kubernetes API Reference。
创建controllers/constants.go文件，用来统一管理常量。 package controllers const ( // 配置 label LabelProvider = "osctest.huawei.com/service_provider" LabelInstance
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
