检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
JMX_PORT=9999" ${KAFKA_HOME}/bin/kafka-server-start.sh \ && sed -i "/kafka-run-class.sh/i\\export KAFKA_OPTS=\"\${KAFKA_OPTS} -javaagent:\$base_dir\/\
实现Controller Controller实现背景 在创建Kafka实例时，Kafka-Operator需要创建的Kubernetes资源如下： 1个StatefulSet，包含3个Pod分别启动ZooKeeper； 1个Service，用来暴露ZooKeeper访问地址；
差异，具体请咨询服务提供商，以服务实例的展示界面为准。以Kafka为例，展示如何变更实例规格。 纵向扩容kafka集群 单击服务实例页面右上角的编辑按钮，编辑服务实例的yaml信息。 在弹出的yaml编辑框中找到kafka和zookeeper的资源描述信息，资源使用情况一般为标准的kubernetes
instance); err != nil { log.Error(err, "Failed to get Kafka") return ctrl.Result{}, client.IgnoreNotFound(err) } for _, component := range
云原生服务中心OSC内置了Prometheus监控能力，服务提供商可以按照自身业务情况，配置所需要展示的服务指标，指标详情查看服务介绍或咨询服务提供商。 以Kafka为例，监控指标分为实例、Broker、Topic三个维度进行展示。 查看监控信息功能仅支持CCE集群。 父主题： 服务实例日常操作
有的服务比较复杂，依赖其它的服务，比如kafka依赖zookeeper，zookeeper的镜像也要放置在images目录下： kafka/ | --- package/ | --- images/ | --- kafka-2.5.0-x86_64.tar
0.0.zip。 包格式：operator类型服务包支持zip格式，helm类型服务包支持tgz格式。 包大小：不超过4MB。 样例（以Kafka为示例）： {OSC-Package}/ ├─ metadata.yaml ├─ manifests/ │ ├─ xxx_crd.yaml
在本章节以Kafka为例，构建Kafka-Operator进行Kafka实例的管理，同时Kafka实例将以三节点集群的形式对外提供服务。对于Kafka实例/集群而言，需要依托于zookeeper进行构建，zookeeper用作Kafka集群的元数据管理，每个Kafka实例在各节点
# UI控件 descriptors: spec: - description: "kafka实例个数" displayName: 集群大小 path: {kafka.replicas} restriction: scenes:
"ops.monitor.kafka.level.pod-slave" groupLabel: pod selectedMetrics: - "kafka_server_ReplicaManager_Value"
io/version: "20.9.3" logPaths: - /var/kafka/ - /var/kafka/access/kafka-access.log 具体参数说明如下： 参数名 含义 类型 是否必填 备注 apiVersion
- image: kafka tag: 2.5.0 address: endpoint: kafka.image.registry repo: kafka.image.repository tag: kafka.image.tag
image：应用的容器镜像地址。 storage：应用数据存储相关配置。 状态 phase：应用实例安装状态。 server：应用访问地址。 以创建一个Kafka应用，指定其Pod数量为3为例，设计CR如下： apiVersion: osctest.huawei.com/v1 kind: Hwfka
#对应创建中间件实例时用户输入的目录，如果不存在，local-pv-immediate会自动创建目录， name: datadir-kafka-event-broker-0 namespace: kafka-alarm spec: accessModes: - ReadWriteOnce resources:
└─ README.md 表1 资源集合结构 目录或文件名称 描述 必选 xxx_crd.yaml 服务包的资源，例如kafka、redis，一个服务包可以包含一个或者多个具体资源目录。 是，至少一个 xxx_csd.yaml 自定义服务文件，每个csd文件对应于一个crd文件。
ui:link 实例status字段具体值信息如下: status: publishedEndpoint: 'http://kafka-1wppvf-broker.default.svc.cluster' 父主题： 自定义控件
go的Manager启动时，创建Controller。 if err = (&controllers.HwfkaReconciler{ Client: mgr.GetClient(), Scheme: mgr.GetScheme(), }).SetupWithManager(mgr);
务代码，就能对接监控、日志等运维能力。 公测 服务规范 2 OSC支持部署复杂服务 复杂服务通常需要依赖其它服务才能完成业务功能，比如Kafka依赖Zookeeper实现集群管理，OSC支持开发者配置复杂服务的依赖，并支持一键部署。 在服务包中，您可以配置服务目录中已有的公共服务的依赖和引用关系：
downloading sigs.k8s.io/controller-runtime v0.10.0 go: downloading k8s.io/client-go v0.22.1 go: downloading k8s.io/utils v0.0.0-20210802155522-efc7438f0176
object represents. Servers may infer this from the endpoint the client submits requests to. Cannot be updated. In CamelCase
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
