Control Center基本使用

登录Control Center

1. 创建阿里云Confluent集群，详情请参见集群开通。

2. 点击集群列表页的“登录控制台”按钮，输入用户名和密码登录进入Control Center页面（用户名为拉起集群时配置的root账户和密码）。

创建Topic

1. 创建Topic。

2. 在Topic test的详情页，点击“Messages” Tab，可以通过UI发送测试数据。目前，UI上发送的测试数据只支持JSON格式。

开启Schema格式校验

1. 点击“Schema” Tab来配置Topic对应的Schema，目前支持三种格式的Schema，常用的是Avro格式和JSON格式。由于UI中只支持发送JSON格式的message，如果您使用UI测试，则必须将Schema设置为JSON类型。

2. 设置Schema格式后，发送和消费数据时默认不开启格式校验（如果您想要开启格式校验，需要修改配置信息）。

3. 开启格式校验配置的路径为，点击Configuration > Edit settings > Switch to expert mode，将其中confluent_value_schema_validation字段设置为true。

查看Broker详情

1. 点击“Broker”按钮，可以查看Broker的基本信息。

2. 进入Metrics详情页，可以查看Producer和Consumer的Throughput，Request latency，Disk使用率等监控指标。

ksqlDB使用

ksqlDB是一个用于Apache kafka的流式SQL引擎，ksqlDB降低了进入流处理的门槛，提供了一个简单的、完全交互式的SQL接口，用于处理Kafka的数据，可以让我们在流数据上持续执行 SQL 查询，ksqlDB支持广泛的强大的流处理操作，包括聚合、连接、窗口、会话等。更多关于ksqlDB的信息请参见KsqlDB官方文档。

1. 架构图

下图分别为传统的流处理应用架构和基于ksqlDB的应用架构示例。通过对比不难看出，流处理引擎以及连接器部分均从之前的独立角色集成到了ksqlDB。除此之外，ksqlDB还通过物化视图提供了流处理过程中的查询功能。

• 传统的流处理应用架构图。

• 基于ksqlDB应用架构图。

2. ksqlDB使用

1. 点击“ksqlDB”按钮进入ksqlDB集群交互详情页。在“Editor” Tab可以执行创建stream、使用ksql命令进行select查询等操作。入门教程请参见KSQL快速使用。

2. 创建Stream。

3. 从stream中查询数据。

SchemaRegistry使用

SchemaRegistry是流数据处理Confluent的核心功能之一，具体操作请参见Schema Registry管理。

1. 查看集群配置

1. 点击“Cluster settings”按钮可以查看集群的基本信息，例如Cluster id。

2. 点击“Cluster defaluts”按钮，可以查看集群的详情信息，包括Controller、Genenal，Group Management等模块。

RBAC授权使用

RBAC全称为Role Based Access Control，是流数据处理Confluent权限管理的核心功能之一，具体操作请参见Control Center页面进行RBAC授权。

告警设置

流数据处理Confluent支持一些业务告警配置，具体操作请参见Control Center设置告警。