我正在阅读Alpakka的文档。在阅读Kafka消费者API时，我遇到了createDrainingControl（），我想知道这个函数有什么用？我知道这用于排空和停止流，但是如果我们不断消耗来自Kafka MQ的消息，为什么我们需要停止流？
最终，您将需要部署新版本的应用程序，您必须停止当前应用程序并启动它的新版本。这可以通过终止旧应用程序来完成，但这会增加重放，超时或错误的数量，这完全取决于您的应用程序的功能。
如果您首先通过排空流来优雅地停止应用程序，则会减少这些不规则的数量。