参考-Control Center官方文档

Control Center是Confluent的核心管理服务，提供了一个可视化的监控平台。

一、进入Control Center

点击集群列表页的“登录控制台”按钮，可以进入Control Center页面； 用户名是拉起集群时配置的root账户和密码
image.png
image.png
image.png

二、创建Topic和开启Schema格式校验

  1. 创建Topic

image.png

  1. 在Topic test的详情页，点击Messages Tab，可以在UI上发送一些测试数据。UI上发送的测试数据只支持JSON格式。

image.png
image.png

  1. 点击Schema Tab来配置Topic相应的Schema，现在支持三种格式的设置，常用的是Avro格式和Json格式。因为在UI上只支持发送Json格式message，所以如果是用UI测试，Schema得设置成Json格式。

image.png

  1. 设置了Schema格式以后，发送和消费数据时，默认是不校验格式。如果想进行格式校验，得改一下配置信息。配置方式是Configuration->Edit settings->Switch to expert mode，将其中confluent_value_schema_validation字段改成true。

image.png
image.png
image.png

三、查看Broker详情

  1. 点击Broker Tab，可以查看Broker的基本信息

image.png

  1. 点击详情，可以产看Producer和Consumer的Throughput，latency，disk等监控指标

image.png

image.png

四、ksqlDB使用

官方链接：ksqlDB介绍
有什么方法能直接查询kafka中已有的数据呢？答案就是使用KSQL。
KSQL是一个用于Apache kafka的流式SQL引擎，KSQL降低了进入流处理的门槛，提供了一个简单的、完全交互式的SQL接口，用于处理Kafka的数据，可以让我们在流数据上持续执行 SQL 查询，KSQL支持广泛的强大的流处理操作，包括聚合、连接、窗口、会话等。

  1. 架构图

下面两张图展示了是否基于ksqlDB的应用架构，对比分析不难看出，对于流处理及连接器，均从之前的独立角色集成到了ksqlDB，ksqlDB除此之外通过物化视图提供了流处理过程中的查询功能。
image.png
基于ksqlDB的应用架构
image.png
基于非ksqlDB的应用架构

  1. 点击KSQL Tab可以创建stream和使用ksql进行select等操作，入门教程可以参考-KSQL快速使用

image.png
创建Stream
image.png
从stream中进行select
image.png

五、SchemaRegistry使用

SchemaRegistry是Confluent的核心功能之一，具体使用可以参考文档-Schema Registry管理教程

六、查看集群配置

  1. 点击Cluster settings，可以查看集群的一些基本信息。Cluster id是集群id，在使用Conluent CLI操作集群时，可以在这里查看集群id。

image.png

  1. 点击Broker defaluts信息，可以看到broker的详情信息，包括broker数量，分布情况，以及访问的域名，配置路径等。

image.png
image.png

image.png

七、RBAC授权使用

RBAC全称是Role Based Access Control，是Confluent权限管理的核心之一，具体使用可以查看文档- RBAC授权

八、告警设置

Confluent支持一些业务告警配置，使用查看文档-Control Center告警设置