KSQL 用于 Apache Kafka 的流数据 SQL 引擎开源项目

KSQL 

用于ApacheKafka的流数据SQL引擎

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

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

点此查看demo

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

项目架构：