KSQL用于 Apache Kafka 的流數(shù)據(jù) SQL 引擎

KSQL 

用于 Apache Kafka 的流數(shù)據(jù) SQL 引擎

注意：項(xiàng)目還處于開發(fā)者預(yù)覽版，請(qǐng)暫時(shí)勿用于生產(chǎn)集群中。

KSQL 是 Apache Kafka 的開源流 SQL 引擎。 它為 Kafka 的流處理提供了一個(gè)簡(jiǎn)單而完整的 SQL 界面; 不需要再用編程語言（如 Java 或 Python ）編寫代碼。 KSQL 是分布式、可擴(kuò)展、可靠的和實(shí)時(shí)的，支持多種流式操作，包括聚合（aggregate）、連接（join）、時(shí)間窗口（window）、會(huì)話（session）等等?；?Apache 2.0 協(xié)議開源。

點(diǎn)此查看demo

KSQL 的兩個(gè)核心概念是流（Stream）和表（Table），它將流和表集成在一起，允許將代表當(dāng)前狀態(tài)的表與代表當(dāng)前發(fā)生事件的流連接在一起。

項(xiàng)目架構(gòu)：