背景 Kafka原本集群磁盘扩容后，新建topic的业务量较大，存在数据积压。一段时间后收到集群节点报警，部分磁盘使用率到达90%警戒值。经过检查发现问题节点各磁盘使用率不均...
IP属地：上海
-
Kafka broker 存储不均衡问题排查记录
-
Flink SQL 实战之 MAP 类型在 UNION ALL 中的妙用
前言 工作当中我们往往会遇到这样的需求场景：某张表中不同的统计指标，需要从多个不同的 kafka 数据源当中统计。这种做法，我们很容易想到把多个 kafka source 统...
-
Flink CEP的基石：NFA-b自动机原理简介前言 Flink的复杂事件处理（complex event processing, CEP）库能够在无界数据流中通过匹配定义好的事件模式来发现一系列事件之间的关联规律，从而有...
