LittleMagic

前言 关于Kafka的一个灵魂拷问：它为什么这么快？或者说，为什么它能做到如此大的吞吐量和如此低的延迟？ 有很多文章已经对这个问题给出了回答，但本文只重点研究其中的一个方向，...

天堂鸟6

转自https://www.cnblogs.com/wuzhenzhao/p/10137490.html 关于 Topic 和 Partition： Topic： 在 kaf...

Woople

基本概念 首先通过官网的一个图片了解一下Asynchronous I/O Operation Flink source收到一条数据就会进行处理，如果需要通过这条数据关联外部数...

知识海洋中的淡水鱼

1 复杂事件 1.1 引入 在Flink RichFunction&state这篇博文中我们一起学习了下如何结合使用keyBy state和TreeSet在一条无界流中进行全...