如何使用 alpakka、spring boot 和 Akka-stream 初始化连续运行的流？

据我所知，Alpakka 的 Spring 集成基本上是围绕通过 Spring HTTP 控制器公开 Akka Streams 设计的。所以我不确定将 Spring 引入其中的目的是什么，因为 Akka 应用程序倾向于喜欢的工作方式与 Spring 应用程序倾向于喜欢的工作方式之间存在相当大的阻抗不匹配。

假设您正在谈论使用 Alpakka Kafka，最惯用的做法是在您的方法中启动由Alpakka KafkaSource提供的流main，它会一直运行直到被杀死或失败。您可能希望在消费者和业务逻辑周围使用RestartSource以确保在发生故障时流重新启动（请注意，通常应该期望没有再次处理偏移提交的消息，如典型的 Kafka案件只能保证至少一次处理）。