KSQL是什么？ KSQL是kafka的sql引擎，可以让我们在流数据上持续执行sql引擎。 例如:有一个用户点击流的topic，和一个可持续更新的用信息表，使用KSQL对点击流数据、用户表进行建模，并把二者连接起来，之后KSQL会持续查询这个topic的数据流，并放入表中。 KSQL 是开源 ...

　　Confluent公司于2017年11月宣布KSQL进化到1.0版本，标志着KSQL已经可以被正式用于生产环境。自那时起，整个Kafka发展的重心都偏向于KSQL——这一点可以从Confluent官方博客中KSQL出现的频率之高看出端倪。鉴于最近周围有很多小伙伴都在讨论KSQL，我突然想起 ...

KSQL函数整理 分类 函数 参数 描述 数学函数 ABS p1 返回给定数值表达式的绝对正 ...

记录常用的kafka常用的topic相关命令 查看topic列表 创建topic --create：创建命令； --topic：后面指定topic名称； --replication-factor：后面指定副本数； --partitions：指定分区数，根据broker的数量决定 ...

kafka版本：kafka_2.12-2.1.1 kafka_port默认9092，zk_port默认2181 查看topicbin/kafka-topics.sh --zookeeper zk_ip:zk_port --list 查看groupbin ...

1.概述 　　上次给大家分享了关于 Kafka SQL 的实现思路，这次给大家分享如何实现 Kafka SQL。要实现 Kafka SQL，在上一篇《Kafka - SQL 引擎分享》中分享了其实现的思路，核心包含数据源的加载，以及 SQL 树的映射。今天笔者给大家分享相关实现的代码。 2. ...

1.概述 　　大多数情况下，我们使用 Kafka 只是作为消息处理。在有些情况下，我们需要多次读取 Kafka 集群中的数据。当然，我们可以通过调用 Kafka 的 API 来完成，但是针对不同的业务需求，我们需要去编写不同的接口，在经过编译，打包，发布等一系列流程。最后才能看到我们预想 ...

1. SQL基础查询 1.1 基本查询语句 Ø SELECT 用于指定要查询的列，如果要查询所有列，在SELECT后面使用“*”号表示，如果查询特定的列，可以直接后面跟指定的列名，列名之间用”,”逗号隔开。 演示：查询所有列 SELECT * FROM dept ...