FlinkFlink 消费 kafka 实现 限流处理 RateLimiter

Posted 2022-03-16 九师兄

文章目录

• 1.概述
• 2.案例
• • 2.1 案例1

1.概述

首先看看 【java】高并发之限流 RateLimiter使用 这个去看看限流怎么使用。

然后看看扩展的kafka是如何限流的，95-10-040-启动-限额管理。

然后下面是FLink如何做限流的。

2.案例

2.1 案例1

public void testRateLimitedConsumer