我应该如何知道何时必须扩展消费者组中的消费者。当存在快速生产者时,消费者扩大规模的触发因素是什么?
一种直接的方法是获取消费者延迟(这可以计算为提交的偏移量和开始偏移量之间的差值),如果最后 n 次计算的延迟正在增加,您可以扩大规模,反之亦然。您可能必须考虑一些边缘情况,例如,如果消费者数量下降并且延迟会增加,并且自动缩放功能可能会产生更多线程/机器)。
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)