面试题十三
问题:Flink程序在面对数据高峰期时如何处理?
解答:
1,使用大容量的Kafka把数据先放到消息队列里面。再使用Flink进行消费,不过这样会影响到一点实时性。
2,使用滚动窗口
3,使用处理时间
4,下游使用消费速度快的外围设备(如Kafka)
问题:Flink程序在面对数据高峰期时如何处理?
解答:
1,使用大容量的Kafka把数据先放到消息队列里面。再使用Flink进行消费,不过这样会影响到一点实时性。
2,使用滚动窗口
3,使用处理时间
4,下游使用消费速度快的外围设备(如Kafka)