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

Question

全,

我正在开发一个应用程序，它使用alpakka spring boot集成来从kafka读取数据。我已经准备好了大部分代码，唯一的问题是如何初始化一个连续运行的流，因为这将是一个后端应用程序，并且不会有任何api可供调用？

Answer 1

据我所知，Alpakka的Spring集成基本上是围绕通过Spring HTTP控制器公开Akka流而设计的。因此，我不确定将Spring引入这个服务的目的是什么，因为在Akka应用程序倾向于工作的方式和Spring应用程序倾向于工作的方式之间存在着相当大的阻抗不匹配。

假设您正在讨论使用Alpakka Kafka，最常用的做法是在您的main方法中启动一个由Alpakka Kafka Source提供的流，它将一直运行到终止或失败。您可能希望在使用者和业务逻辑周围使用RestartSource，以确保在发生故障时流重新启动(请注意，通常情况下，人们应该期望偏移量提交没有发生的消息再次被处理，因为Kafka在典型情况下只能保证至少处理一次)。