有的时候需要检出Kafka中某个topic的所有partition的offset range. 比如Spark S...[作者空间]
在我司的风电大数据项目中，出现了一个报错 我司为了实现Exactly Once的语义，采取了自行保管offset的...[作者空间]
Spark SQL 是 Spark 处理结构化数据的一个模块.与基础的 Spark RDD API 不同, Spa...[作者空间]
嗯目前文档里几乎没有提到…… 但是，An issuesis here with an offical explan...[作者空间]
有什么用？ 以前我们拿kafka当作一个data hub，用来传输数据，扔进数据库。KSQL使得我们可以直接拿ka...[作者空间]
