面试题十三

问题:Flink程序在面对数据高峰期时如何处理?

解答:

1,使用大容量的Kafka把数据先放到消息队列里面。再使用Flink进行消费,不过这样会影响到一点实时性。

2,使用滚动窗口

3,使用处理时间

4,下游使用消费速度快的外围设备(如Kafka)