文档

Control Center基本使用

更新时间:
一键部署

Control Center是流数据服务Confluent的核心管理服务,提供了一个可视化的监控平台。本文介绍Control Center平台上的基本操作。详细的Control Center用户指南请参见Control Center官方文档

登录Control Center

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

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

imageimage

创建Topic

  1. 创建Topic。

说明

本文创建名为test的Topic进行演示。

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

imageimage

开启Schema格式校验

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

image
  1. 设置Schema格式后,发送和消费数据时默认不开启格式校验(如果您想要开启格式校验,需要修改配置信息)。

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

imageimageimage

查看Broker详情

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

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

image

image

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快速使用

imageimage
  1. 创建Stream。

  1. 从stream中查询数据。

SchemaRegistry使用

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

1. 查看集群配置

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

说明

Cluster id可用于通过Conluent CLI操作集群。

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

image

RBAC授权使用

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

告警设置

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

  • 本页导读 (0)
文档反馈