apache-kafka - 卡夫卡论公共(public)交通

标签 apache-kafka masstransit saga

我正在研究使用 Kafka 的可能性 Masstransit在我们的信息系统上。公共(public)交通文档称 Kafka 可以使用,但作为 Rider ;由于必须使用传输,因此除了 Kafka 和 Masstransit 之外,我们还必须使用其他工具(如 ActiveMQ、RabbitMQ)。

传输有哪些 Kafka 无法完成的功能,从而阻止了 Kafka 的独占使用?

最佳答案

MassTransit 的设计考虑到了竞争消费者的发布-订阅模式,这是使用消息代理时的默认模式。

正如文档中提到的,Riders 被引入作为事件流和发布-订阅之间的网关。因此,乘客的主要目的是支持当您需要消费来自乘客的消息并将其发布到公交车时的场景。甚至生产者对于骑手来说也是可选的,并且它们是特定于实现的。由于像 Kafka 这样的事件流基础设施甚至不支持竞争消费者,因此制作像 Kafka 传输这样的东西没有什么意义,因为它在 MassTransit 概念和 Kafka 所做的事情之间引入了严重的阻抗不匹配。

您仍然可以将 Kafka 与 MassTransit 结合使用,但您需要使用内存传输来配置和启动总线。

关于apache-kafka - 卡夫卡论公共(public)交通,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/68918037/

相关文章:

java - 在kafka中消费批处理时如何部分提交同步

hadoop - Hive 为 HDFS 中的每个插入创建多个小文件

c# - MassTransit 消费者的 XUnit 单元测试

unit-testing - 当 Saga 有多个处理程序时,如何为 NServiceBus Saga 创建单元测试

unit-testing - 单元测试 redux-saga 任务取消

apache-kafka - Ktable Ktable 连接示例

apache-kafka - Kafka : Error from SyncGroup, 请求超时

c# - MassTransit 注册多个相同消息类型的消费者

publish-subscribe - 具有 MassTransit 的发布者/订阅者架构

ios - React Native 应用程序在 Debug模式下工作,但在 iOS 上不工作 Release模式