当前位置:   article > 正文

RocketMQ和Kafka的区别,以及如何保证消息不丢失和重复消费_mq和kafka怎么保证消息的一致性

mq和kafka怎么保证消息的一致性

消息队列RocketMQ和Kafka的区别

性能(单台) 语言 多语言支持客户端 优缺点
RocketMQ 十万级 java java
  • 模型简单、接口易用,在阿里有大规模应用
  • 文档少,支持的语言少
Kafka 百万级 服务端scala,客户端java 主流语言均支持
  • 天生分布式、性能最好,常用于大数据领域
  • 运维难度大,对zookeeper强依赖,多副本机制下对带宽有一定要求
  • RocketQA适用于高性能、高可用的消息传递场景,具有丰富的消息过滤和分布式事务特性;
  • Kafka适用于高吞吐量、低延迟的实时数据处理和事件驱动的架构场景,具有良好的可伸缩性和持久性

Kafka 消费顺序、消息丢失和重复消费

Kafka 采用的是发布 - 订阅模型。

RocketMQ 的消息模型和 Kafka 基本是完全一样的。唯一的区别是 Kafka 中没有队列这个概念,与之对应的是 Partition(分区)

Kafka的多副本机制

Kafka 为分区(Partition)引入了多副本(Replica)机制。

分区(Partition)中的多个副本之间会有一个叫做 leader 的家伙,其他副本称为 follower。我们发送的消息会被发送到 leader 副本,然后 follower 副本才能从 leader 副本中拉取消息进行同步。生产者和消费者只与leader副本做交互。

Kafka 的

声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/知新_RL/article/detail/603372
推荐阅读
相关标签
  

闽ICP备14008679号