KSQL用于 Apache Kafka 的流数据 SQL 引擎

KSQL 

用于 Apache Kafka 的流数据 SQL 引擎

注意：项目还处于开发者预览版，请暂时勿用于生产集群中。

KSQL 是 Apache Kafka 的开源流 SQL 引擎。 它为 Kafka 的流处理提供了一个简单而完整的 SQL 界面; 不需要再用编程语言（如 Java 或 Python ）编写代码。 KSQL 是分布式、可扩展、可靠的和实时的，支持多种流式操作，包括聚合（aggregate）、连接（join）、时间窗口（window）、会话（session）等等。基于 Apache 2.0 协议开源。

点此查看demo

KSQL 的两个核心概念是流（Stream）和表（Table），它将流和表集成在一起，允许将代表当前状态的表与代表当前发生事件的流连接在一起。

项目架构：