Akka Stream卡夫卡vs卡夫卡流 [英] Akka Stream Kafka vs Kafka Streams
问题描述
我目前正在使用 Akka Stream Kafka 与kafka进行交互，我想知道与 Kafka流有什么区别。
I am currently working with Akka Stream Kafka to interact with kafka and I was wonderings what were the differences with Kafka Streams.
我知道，基于Akka的方法可以实现反应性规范并可以处理kafka流似乎缺乏的反压功能。
I know that the Akka based approach implements the reactive specifications and handles back-pressure, functionality that kafka streams seems to be lacking.
使用akafka流比akka流kafka有什么优势？
What would be the advantage of using kafka streams over akka streams kafka?
推荐答案
您的问题非常笼统，因此我将从我的角度给出一个笼统的答案。
Your question is very general, so I'll give a general answer from my point of view.
首先，我有两种使用情况：
First, I've got two usage scenario:
- 从中读取数据的情况kafka，对其进行处理，并将一些输出写回到kafka，因为这些我只使用kafka流。
- 这种情况下，数据源或接收器都不是kafka，对于我
这已经使我能够回答有关背压的问题：在上述第一种情况下，存在背压
This already allows me to answer the part about back-pressure: for the 1st scenario above, there is a back-pressure mechanism in kafka streams.
现在让我们只关注上述第一种情况。让我们看看如果我决定停止使用Kafka流，我会放松：
Let's now only focus on the first scenario described above. Let's see what I would loose if I decided to stop using Kafka streams:
- 我的某些流处理器阶段需要持久的（分布式）状态商店，kafka streams为我提供了它。这是akka流所不提供的。
- 扩展后，kafka流会在启动新的流处理器实例时或一旦被杀死时自动平衡负载。 。这可以在同一个JVM中以及在其他节点上工作：向上扩展和向外扩展。
这些对我来说是最大的区别，我希望你！
Those are the biggest differences that matter to me, I'm hoping that it makes sense to you!
这篇关于Akka Stream卡夫卡vs卡夫卡流的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！
