我现在有个专门消费消息的系统，怎么动态控制，让不同的机器（容器、节点、pod）消费不同的队列呢？

我现在有个专门消费消息的系统，跑在 k8s 集群里。怎么动态控制，让不同的机器（容器、节点、pod ）消费不同的队列呢？

逻辑都是通用的，但可能会有很多渠道的消息送过来。不同渠道消息可以用一个队列，也可以用多个队列。

但是不通渠道的消息流量大小也不同，某些渠道的流量可能会比较大，消息也很多，需要更多的节点去处理。

那我想指定某些 pod 去消费某个队列的消息，有什么好办法呢？

比如我这个应用一个创建了 20 个副本，我想让其中 10 副本个消费 A 队列，5 个消费 B 队列，5 个消费 C 队列。

而且这个副本数可以动态控制，随时增加（重启生效也可以）。