Akka Stream Kafka与Kafka Streams的比较
我目前正在使用Akka Stream Kafka与kafka进行交互，并想知道它与Kafka Streams的区别。 我知道基于Akka的方法实现了反应式规范并处理了背压，而Kafka Streams似乎缺乏这种功能。 使用Kafka Streams而不是Akka Streams Kafk...
实践中，小批量处理和实时流处理有什么区别？
在实践中，小批量和实时流有哪些区别（不是理论上的差异）？理论上，我理解小批量是在给定时间内批处理数据，而实时流更像是随着数据到达进行操作，但我最大的问题是为什么不能在 epsilon 时间范围内使用小批量（比如说一毫秒）或者说我想了解一个方法为什么比另一个方法更有效？ 我最近遇到一个例子，其...
Kafka Python API是否支持流处理？
我在Java中使用了Kafka Streams，但在Python中找不到类似的API。 Apache Kafka是否支持Python中的流处理？
Apache Spark和Apache Apex有什么区别？
Apache Apex 是一款开源的企业级统一流处理和批处理平台。它被用于GE Predix平台的IOT。 问题 从数据科学的角度来看，它与Spark有何不同之处？ Apache Apex是否提供类似于Spark MLlib的功能？如果我们需要在Apache Apex上构建可扩展的ML模...
真实世界的TIS-100模拟
最近的游戏TIS-100围绕一个相当有趣的机器架构展开，其中CPU由“节点”组成，这些节点可以与其相邻的邻居进行通信。不幸的是，我无法找到官方链接以供公众讨论参考手册，但总的来说，每个节点支持非常简单的ISA，但并行运行在同一时钟上。每个节点有两个寄存器，一个ACC寄存器和一个BCK辅助寄存器...
Apache Beam 基于 Apache Kafka 的流处理
Apache Beam和Apache Kafka在流处理方面有哪些不同之处？我试图理解技术和编程上的区别。 请通过你的经验帮助我理解。
Akka Stream中的asyncBoundary和mapAsync区别
我想了解asyncBoundary和mapAsync之间的区别。从表面上看，它们应该是相同的。但是，当我运行代码时，asyncBoundary的性能似乎比mapAsync更快。 以下是代码： implicit val system = ActorSystem("sourceDemo") i...
如何通过编程方式终止Apache Storm拓扑？
我正在使用一个Java类来向Storm集群提交拓扑，并计划使用一个Java类来杀死这个拓扑。但是根据Storm的文档，杀死拓扑使用以下命令，而没有Java方法（这有其有效的原因）。storm kill {stormname} 从Java类调用Shell脚本来杀死拓扑是否可行？还有哪些其他方法可...
Apache Apex和Apache Storm有什么不同？
Apache Apex 看起来与 Apache Storm 非常相似。 用户在两个平台上都将应用程序/拓扑构建为有向无环图(DAG)。Apex使用操作符/流，而Storm使用spouts/streams/bolts。 它们都以实时方式处理数据，而不是批处理。 似乎两者的吞吐量和延迟都很高。...