Control Center is the built-in web interface for ApsaraMQ for Confluent. Use it to create topics, configure schemas, monitor broker health, and manage cluster-level settings from a single dashboard.
Each page in Control Center maps to a management task:
| Page | What it does |
|---|---|
| Home | Displays the cluster card for navigating into cluster management |
| Topics | Create, configure, and monitor topics. Set up schemas and validation rules |
| Brokers | Monitor broker health, throughput, latency, and disk usage |
| Cluster settings | View and manage cluster-level configurations |
| ksqlDB | Run streaming SQL queries against Kafka data in real time |
| RBAC | Manage role-based access control (RBAC) for users and resources |
| Alerts | Configure monitoring alerts for cluster events |
Prerequisites
Before you begin, make sure that you have:
An ApsaraMQ for Confluent instance deployed and running
The root user credentials (username and password) configured during instance deployment
Log on to Control Center
Log on to the ApsaraMQ for Confluent console. In the left-side navigation pane, click Instances.
In the top menu bar, select a region. On the Instances list page, click the name of the target instance.
On the Instance Details page, click Log on to Console in the upper-right corner.
NoteThe username and password are the root user credentials configured during instance deployment.
The Home page of Control Center opens after you log on.
Create a topic
A topic is a named stream of messages. Producers write data to topics, and consumers read from them.
On the Home page, click the controlcenter.clusterk card to open the Cluster overview page.
In the left navigation pane, click Topics. On the Topics list page, click + Add topic.
On the New topic page, enter a unique topic name and set the number of partitions. Click Create with defaults.
The topic details page opens, confirming successful creation.
Set up schema validation
Schema validation enforces a data format for messages produced to a topic. When enabled, format validation occurs during data transmission and consumption. To set it up, create a schema and then enable validation in the topic configuration.
Create a schema
On the topic details page, click the Schema tab, then click Set a schema.
Select a schema for validation, define the validation rule, and click Create.
Enable validation
On the topic details page, click the Configuration tab, then click Edit settings.
Click Switch to expert mode.
Set
confluent_value_schema_validationtotrue, then click Save changes. After you save, format validation occurs during data transmission and consumption.
Monitor brokers
The Brokers page shows the health and performance of all brokers in your cluster.
On the Cluster overview page, click Brokers in the left navigation pane to view basic broker information.
On the Brokers overview page, click Production or Consumption to view monitoring metrics such as Producer and Consumer throughput, request latency, and disk usage.
View cluster configurations
In the left navigation pane, click Cluster settings to view cluster information.
Click the Cluster defaults tab to inspect detailed configuration settings. Settings are organized into the following modules:
Module Description Controller Controller-related settings for the cluster General Core Kafka broker configurations Group Management Consumer group coordination settings
Use ksqlDB
ksqlDB is an open-source streaming SQL engine for processing and analyzing Kafka data streams in real time using SQL-like syntax. It simplifies Kafka stream processing.
For setup instructions and query examples, see ksqlDB.
Manage access with RBAC
RBAC (role-based access control) is a core feature for permission management in ApsaraMQ for Confluent. It lets you define granular permissions for users across your Confluent cluster resources.
For configuration steps, see RBAC authorization.
Configure alerts
ApsaraMQ for Confluent supports alert configurations to help you monitor cluster events.
For step-by-step instructions, see Configure alerting in Control Center.
What's next
For advanced topic management, consumer group monitoring, and other operations, see the Confluent official documentation.
To process streaming data with SQL, see ksqlDB.
To set up permissions for your team, see RBAC authorization.