为什么Flink使用Akka进行rpc？

Question

Akka 程序更难调试。我们还需要跟踪许多参与者的状态来诊断问题。有什么解释为什么 Flink 选择 Akka 吗？

Answer 1

Flink 项目决定使用 Akka 来实现其底层 RPC 服务，因为 Akka 可以为您完成大部分繁重的工作。Akka 可以轻松实现异步 RPC，支持加密等企业功能，并达到不错的消息吞吐量。

但请注意，无论使用的 RPC 系统如何，如果您想要调试分布式系统，您始终必须监视多个组件并可能关联不同的日志文件。这是分布式数据处理框架固有的问题。

此外，Akka rpc 服务实现AkkaRpcService只是 Flink 的一种实现RpcService。没有什么根本原因可以解释为什么人们不能用基于不同网络库（例如Aeron ）AkkaRpcService的实现来替换该实现。