KSQL是什么?
KSQL是kafka的sql引擎,可以让我们在流数据上持续执行sql引擎。
例如:有一个用户点击流的topic,和一个可持续更新的用信息表,使用KSQL对点击流数据、用户表进行建模,并把二者连接起来,之后KSQL会持续查询这个topic的数据流,并放入表中。
KSQL 是开源的、分布式、具有高可靠、可扩展、实时的特性
KSQL 支持强大的流处理操作,包括聚合、连接、窗口、会话等。
KSQL解决了什么问题?
KSQL的主要目的是为了降低流处理的操作门槛,为kafka提供了简单而完善的SQL交互接口
之前,为了使用流处理引擎,需要熟悉一些开发语言,例如java、python,kafka的流处理引擎作为kafka项目的一部分,是一个java库,需要使用者有熟悉的java技能,而KSQl只需要使用者熟悉SQL即可,并使得Kafka Stream 能够进入更广阔的应用领域,例如商业分析。
KSQL的应用场景?
1、实时监控、实时分析
KSQL可以让我们对