我正在阅读 Alpakka 的文档。在阅读Kafka消费者API时，我遇到了createDrainingControl()，我想知道这个函数有什么用？我知道这是用来排空和停止流的，但是如果我们不断地消耗来自 Kafka MQ 的消息，为什么我们需要停止流？
最终，您将需要部署应用程序的新版本，您必须停止当前应用程序并启动它的新版本。这总是可以通过终止旧应用程序来完成，但这会增加重播、超时或错误的数量，这一切都取决于您的应用程序所做的事情。
相反，如果您通过先排空流来优雅地停止应用程序，则会减少这些不规则的数量。
本文收集自互联网，转载请注明来源。
如有侵权，请联系 [email protected] 删除。
我来说两句