全部產品
Search
文件中心

ApsaraMQ for Kafka:Control Center基本使用

更新時間:May 27, 2025

Control Center是雲訊息佇列 Confluent 版的核心管理服務,提供了一個可視化的監控平台。本文介紹Control Center平台上的基本操作。

登入Control Center

  1. 登入雲訊息佇列 Confluent 版控制台,在左側導覽列,單擊实例列表

  2. 在頂部功能表列,選擇地區,然後在執行個體列表頁面,單擊目標執行個體名稱。

  3. 实例详情頁面,單擊右上方的登入控制台進行Control Center登入。

    說明

    Control Center控制台的登入使用者名稱和密碼為部署執行個體時配置名為root的使用者名稱和密碼。

    image

  4. 登入完成後,進入Control Center控制台的Home頁面。

    image

建立Topic

  1. 登入Control Center控制台,在Home頁面單擊controlcenter.clusterk卡片,進入到Cluster overview頁面。

    image

  2. 在左側導覽列,單擊Topics,然後在Topic列表頁面單擊+ Add topic

    image

  3. New topic頁面,設定Topic名稱和分區數,然後單擊Create with defaults

    image

  4. 建立完成後,進入到Topic詳情頁面。

    image

開啟Schema格式校正

建立Schema

  1. Topic詳情頁面,單擊Schema,然後單擊Set a schema

  2. Schema頁簽,選擇Schema校正格式,填寫校正規則後,單擊Create

    image

開啟Schema格式校正

  1. 在Topic詳情頁面,單擊Configuration頁簽,然後單擊Edit settings

    image

  2. 然後單擊Switch to expert mode

    image

  3. confluent_value_schema_validation欄位設定為true,然後單擊Save changes,啟用Schema驗證訊息內容格式。啟用後發送和消費資料時將進行格式校正。

    image

查看Broker詳情

  1. Cluster overview頁面的左側導覽列,單擊Brokers,查看Broker的基本資料。image.png

  2. Brokers overview頁面,單擊ProductionConsumption,進入Metrics詳情頁,查看Producer和Consumer的Throughput,Request latency,Disk使用率等監控指標。imageimage

使用KsqlDB

KsqlDB是一款開源流式SQL引擎,能夠藉助類SQL文法即時處理與分析Kafka中的資料流,從而簡化了Kafka流處理的複雜性。具體操作請參見KsqlDB

查看叢集配置

  1. 在首頁的左側導覽列,單擊Cluster settings,查看叢集的基本資料。

  2. 單擊Cluster defaults頁簽,查看叢集的詳情資訊,包括Controller、Genenal,Group Management等模組。

RBAC授權使用

RBAC即角色型存取控制(Role Based Access Control),是雲訊息佇列 Confluent 版許可權管理的核心功能之一,具體操作請參見RBAC授權

警示設定

雲訊息佇列 Confluent 版支援一些業務警示配置,具體操作,請參見Control Center設定警示