有没有小伙伴知道flink消费 kafka怎么设置消费速率？我这边程序启动后反压太大，想降低flink消费kafka的速率，但是找了一圈资料，发现也没啥参数能设置。。。在FlinkKafkaConsumer源码中找到了flink.poll-timeout这个参数，但是发现通过properties设置该参数到FlinkKafkaConsumer中并不能生效
有没有小伙伴知道flink消费kafka怎么设置消费速率？[阿里云实时计算 Flink版]
「点点赞赏，手留余香」
还没有人赞赏，快来当第一个赞赏的人吧！