Control Center是云消息队列 Confluent 版的核心管理服务,提供了一个可视化的监控平台。本文介绍Control Center平台上的基本操作。
登录Control Center
登录云消息队列 Confluent 版控制台,在左侧导航栏,单击实例列表。
-
在顶部菜单栏,选择地域,然后在实例列表页面,单击目标实例名称。
-
在实例详情页面,单击右上角的登录控制台进行Control Center登录。
说明Control Center控制台的登录用户名和密码为部署实例时配置名为root的用户名和密码。
-
登录完成后,进入Control Center控制台的Home页面。
页面显示集群健康状态(Healthy clusters 和 Unhealthy clusters 徽标),以及集群卡片,其中包含集群名称、运行状态和概览信息(Brokers、Partitions、Topics、Production、Consumption),以及已连接的 ksqlDB clusters 和 Connect clusters 服务数量。
创建Topic
-
登录Control Center控制台,在Home页面单击controlcenter.clusterk卡片,进入到Cluster overview页面。
页面左侧导航菜单包含 Cluster overview、Brokers、Topics、Consumers 等选项,右侧展示集群 Brokers 和 Topics 概览信息。
-
在左侧导航栏,单击Topics,然后在Topic列表页面单击+ Add topic。
-
在New topic页面,设置Topic名称和分区数,然后单击Create with defaults。
例如,将 Topic name 设置为
transactions,将 Number of partitions 设置为1。 -
创建完成后,进入到Topic详情页面。
页面包含Overview、Messages、Schema、Configuration四个Tab页签,Overview页签展示Production(生产速率)、Consumption(消费速率)及Availability(可用性)指标。
开启Schema格式校验
创建Schema
-
Topic详情页面,单击Schema,然后单击Set a schema。
-
在Schema页签,选择Schema校验格式,填写校验规则后,单击Create。
可选的 Schema 校验格式包括 JSON Schema、Avro 和 Protobuf。
开启Schema格式校验
-
在Topic详情页面,单击Configuration页签,然后单击Edit settings。
-
然后单击Switch to expert mode。
-
将confluent_value_schema_validation字段设置为true,然后单击Save changes,启用Schema验证消息内容格式。启用后发送和消费数据时将进行格式校验。
查看Broker详情
-
在Cluster overview页面的左侧导航栏,单击Brokers,查看Broker的基本信息。
-
在Brokers overview页面,单击Production或Consumption,进入Metrics详情页,查看Producer和Consumer的Throughput,Request latency,Disk使用率等监控指标。Brokers Overview 页面分为 Production 和 Consumption 两列,每列分别展示 Throughput(吞吐量)和 Request latency 95th percentile(请求延迟)折线图。

使用KsqlDB
KsqlDB是一款开源流式SQL引擎,能够借助类SQL语法实时处理与分析Kafka中的数据流,从而简化了Kafka流处理的复杂性。具体操作请参见KsqlDB。
查看集群配置
-
在主页的左侧导航栏,单击Cluster settings,查看集群的基本信息。
-
单击Cluster defaults页签,查看集群的详情信息,包括Controller、Genenal,Group Management等模块。
RBAC授权使用
RBAC即基于角色的访问控制(Role Based Access Control),是云消息队列 Confluent 版权限管理的核心功能之一,具体操作请参见RBAC授权。
告警设置
云消息队列 Confluent 版支持一些业务告警配置,具体操作,请参见Control Center设置告警。
其他资源管理
其他资源管理操作,如Topic管理、Consumer Group管理等,请参见Confluent官方文档。