scala – Akka Stream Kafka vs Kafka Streams

发布时间：2020-12-16 09:30:07 所属栏目：安全来源：网络整理

导读：我目前正在与 Akka Stream Kafka合作与kafka互动，我很惊讶与 Kafka Streams有什么不同。我知道基于Akka的方法实现了反应性规范并处理了kafka流似乎缺乏的背压和功能。使用kafka流比akka stream kafka有什么好处？解决方法你的问题非常笼统，所以我会从

我目前正在与 Akka Stream Kafka合作与kafka互动，我很惊讶与 Kafka Streams有什么不同。

我知道基于Akka的方法实现了反应性规范并处理了kafka流似乎缺乏的背压和功能。

使用kafka流比akka stream kafka有什么好处？

解决方法

你的问题非常笼统，所以我会从我的观点给出一般性答案。

首先，我有两个使用场景：

>我正在从kafka读取数据，处理它并将一些输出写回kafka的情况，因为我只使用kafka流。
>对于那些我使用akka流的人来说，数据源或接收器不是kafka的情况。

这已经允许我回答关于背压的部分：对于上面的第一种情况，在卡夫卡流中存在背压机制。

现在让我们只关注上述第一种情况。如果我决定停止使用Kafka流，那么让我们看看会放松一下：

>我的一些流处理器阶段需要一个持久(分布式)状态存储，kafka流为我提供它。这是akka溪流不提供的东西。
>扩展，kafka流会在启动流处理器的新实例时立即自动平衡负载，或者一旦被杀死，就会自动平衡负载。这适用于同一个JVM以及其他节点：扩展和扩展。这不是由akka流提供的。

这些是对我来说最重要的差异，我希望你对它有意义！

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!