Re:Flink SQL消费kafka topic有办法限速么？

Tue, 28 May 2024 07:01:06 -0700 

查了下Flink源码，当前DataGeneratorSource有添加RateLimiterStrategy参数，但KafkaSource没有该参数，可以像DataGeneratorSource那样来实现限速么？

public DataGeneratorSource(

        GeneratorFunction<Long, OUT> generatorFunction,

        long count,

        RateLimiterStrategy rateLimiterStrategy,

        TypeInformation<OUT> typeInfo) {...}

















在 2024-05-27 23:47:40，"casel.chen" <casel_c...@126.com> 写道：
>Flink SQL消费kafka topic有办法限速么？场景是消费kafka 
>topic数据写入下游mongodb，在业务高峰期时下游mongodb写入压力大，希望能够限速消费kafka，请问要如何实现？

回复