实时计算系统，擅长处理海量数据，适用于数据实时处理而非批处理。 批处理使用的大多是鼎鼎大名的hadoo ...

写这篇博客的目的 让更多的人了解 阿里开源的MongoShake可以很好满足mongodb到kafka高性能高可用实时同步需求（项目地址：https://github.com/alibaba/Mon ...

flink 触发器 触发器确定窗口(由窗口分配程序形成)何时准备由窗口函数处理。每个WindowAssigner都带有一个默认触发器。 如果默认触发器不适合需求，我们就需要自定义触发器。 主要方法 ...

使用的flink版本：1.9.1 异常描述 需求： 从kafka读取一条数据流 经过filter初次筛选符合要求的数据 然后通过map进行一次条件判断再解析。这个这个过程中可能返回 ...

需求与场景 上游某业务数据量特别大，进入到kafka一个topic中(当然了这个topic的partition数必然多，有人肯定疑问为什么非要把如此庞大的数据写入到1个topic里，历史留下的问题， ...

关于分配器介绍内容来自官网 窗口分配的概念 窗口分配程序（Window Assigners）定义如何将元素分配给窗口。 通过window(...) (for keyed streams)或wind ...

原文链接：https://mp.weixin.qq.com/s/uwmLR-1Jo_VNXRFA0yYWlg Apache Pulsar是一个企业级的发布订阅（pub-sub）消息系统，最初由 ...