试着尝试一下Confluent Platform的演示(ksqlDB版)【第5次】
概述
我想利用此次的第一次搭建的Confluent集群登录到Confluent Control Center,然后尝试确认ksqlDB的功能。
登录到Confluent Control Center。
1. 请使用以下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界面来进行操作,对运营人员来说非常方便易用。
下次我想要讨论有关消费者的话题。感谢您一直阅读到最后!