从代码上看，Flink 内部是有限速的组件的。org.apache.flink.api.common.io.ratelimiting.GuavaFlinkConnectorRateLimiter， 但是并没有在connector中使用。
casel.chen <casel_c...@126.com> 于2024年6月5日周三 14:36写道： > kafka本身是支持消费限流的[1]，但这些消费限流参数在flink kafka sql > connector中不起作用，请问这是为什么？如何才能给flink kafka source table消费限速? 谢谢！ > > > [1] https://blog.csdn.net/qq_37774171/article/details/122816246
