kafka consumer config里面有一些配置参数可以达到限速功能，例如 max.partition.fetch.bytes fetch.max.bytes max.poll.records 详情可以参考 https://kafka.apache.org/24/documentation.html#consumerconfigs
在 2022-09-26 23:27:30，"yidan zhao" <hinobl...@gmail.com> 写道： >应该不行吧，kafka client本身就没有限速的功能。 > >Jason_H <hyb_he...@163.com> 于2022年9月26日周一 10:17写道： >> >> Hi，各位大佬： >> 我们在使用flink消费kafka的时候，是否可以在代码中自定义消费速率，来调整源端的消费能力。 >> >> >> | | >> Jason_H >> | >> | >> hyb_he...@163.com >> |
