试着尝试一下Confluent Platform的演示（ksqlDB版）【第5次】

概述

我想利用此次的第一次搭建的Confluent集群登录到Confluent Control Center，然后尝试确认ksqlDB的功能。

登录到Confluent Control Center。

１. 请使用以下URL从网络浏览器访问Confluent控制中心的图形用户界面(GUI)。

http://localhost:9021

在这里，可以确认ksqlDB已经通过身份验证连接到Kafka集群，并且已经执行了在ksqlDB命令文件中定义的查询。

docker-compose exec ksqldb-cli bash -c 'ksql -u ksqlDBUser -p ksqlDBUser http://ksqldb-server:8088'

SELECT 1/0 FROM wikipedia EMIT CHANGES;

这个查询不应该返回任何记录。ksqlDB会为每个记录在处理日志中写入错误。在这里，我们将在ksqlDB编辑器中显示相应的ksqlDB流”KSQL_PROCESSING_LOG”。(同时设置auto.offset.reset=Earliest)

SELECT * FROM KSQL_PROCESSING_LOG EMIT CHANGES;

我认为ksqlDB可以通过SQL类似的语法来访问Kafka的数据，并且可以通过GUI界面来进行操作，对运营人员来说非常方便易用。

下次我想要讨论有关消费者的话题。感谢您一直阅读到最后！