akka - createDrainingControl 的目的是什么？

Question

我正在阅读 Alpakka 的文档。在阅读 Kafka 消费者 API 时，我遇到了 createDrainingControl()，我想知道这个函数有什么用？我知道这是用来排空和停止流的，但是如果我们不断地消耗来自 Kafka MQ 的消息，为什么我们需要停止流呢？

Answer 1

最终，您将需要部署一个新版本的应用程序，您必须在其中停止当前应用程序并启动它的新版本。这总是可以通过杀死旧应用程序来完成，但这会增加重放、超时或错误的数量，这一切都取决于您的应用程序所做的事情。

相反，如果您通过先排空流来优雅地停止应用程序，它会减少这些不规则性的数量。