milvus/pkg/mq
yihao.dai de78de7689
fix: [10kcp] Fix consume blocked due to too many consumers (#38456)
This PR limits the maximum number of consumers per pchannel to 10 for
each QueryNode and DataNode.

issue: https://github.com/milvus-io/milvus/issues/37630

pr: https://github.com/milvus-io/milvus/pull/38455

---------

Signed-off-by: SimFG <bang.fu@zilliz.com>
Signed-off-by: bigsheeper <yihao.dai@zilliz.com>
Co-authored-by: SimFG <bang.fu@zilliz.com>
2024-12-13 21:20:47 +08:00
..
common enhance: [2.4] get msg type from the msg header to reduce the Unmarshal usage (#36454) 2024-09-26 16:41:15 +08:00
mqimpl/rocksmq fix: rocksmq consume too slow if the channel is full (#36618) 2024-10-09 11:59:31 +08:00
msgdispatcher fix: [10kcp] Fix consume blocked due to too many consumers (#38456) 2024-12-13 21:20:47 +08:00
msgstream enhance: [2.4] force to stop buffer message when receiving the drop collection message (#36917) 2024-10-17 12:53:29 +08:00