正如1.23号组会上提到的，通过消息队列堆积程度动态控制监听函数的并发度。 具体来说： Runtime为每个stream后都分配一个消息队列，一方面是作为异步的分割点，形成消息订阅的模式。另一方面是Runtime的监控点，监控流量的大小。 当消息队列出现堆积或者减流时，需要动态调整消费者的并发度，以实现对流的维护。 当流堆积超过阈值需考虑硬停止流、部分丢弃或者直接系统崩溃；干涸时间超过阈值则考虑休眠流后内容以释放资源。
正如1.23号组会上提到的，通过消息队列堆积程度动态控制监听函数的并发度。
具体来说：
Runtime为每个stream后都分配一个消息队列，一方面是作为异步的分割点，形成消息订阅的模式。另一方面是Runtime的监控点，监控流量的大小。
当消息队列出现堆积或者减流时，需要动态调整消费者的并发度，以实现对流的维护。
当流堆积超过阈值需考虑硬停止流、部分丢弃或者直接系统崩溃；干涸时间超过阈值则考虑休眠流后内容以释放资源。