flink消费rabbitmq，设置prefetch count不生效有人碰到过吗

楼主你好，不生效的原因，你可以从这方面入手： prefetch_count生效的条件和特性（从参数设置的一些demo和源码上感知）： prefetch_count参数仅仅在basic.consume的autoAck参数设置为false的前提下才生效，也就是不能使用自动确认，自动确认的消息没有办法限流。 basic.consume如果在非自动确认模式下忘记了手动调用basic.ack，那么prefetch_count正是未ack消息数量的最大上限。 prefetch_count是由RabbitMQ服务端控制，一般情况下能保证各个消费者线程中的未ack消息分发是均衡的，这点笔者猜测是consumerTag起到了关键作用。

我觉得这是因为RabbitMQ的prefetch count只对每个消费者有效，而Flink消费RabbitMQ时，会创建多个消费者，每个消费者的prefetch count都是默认值1，所以设置prefetch count不会生效。 要解决这个问题，你可以在Flink消费RabbitMQ时，设置每个消费者的prefetch count，这样就可以控制每个消费者一次从队列中拉取的消息数量了。