RocketMQ有一个对其扩展的开源项目incubator-rocketmq-externals,这个项目中有一个子??榻小皉ocketmq-c...
RocketMQ有一个对其扩展的开源项目incubator-rocketmq-externals,这个项目中有一个子??榻小皉ocketmq-c...
RabbitMQ集群架构模式 主备模式 实现RabbitMQ的高可用集群,一般在并发和数据量不高的情况下,这种模式非常的好且简单。主备模式也称为...
kafka重复消费的根本原因就是“数据消费了,但是offset没更新”!而我们要探究一般什么情况下会导致offset没更新? max.poll....
“持久化”可以提高RabbitMQ的可靠性,以防在异常情况(重启、关闭、宕机等)下的数据丢失。RabbitMQ的持久化分为三个部分:交换器的持久...
1 Producer 一个应用尽可能用一个Topic,消息子类型用tags来标识,tags可以由应用自由设置 只有发送消息设置了tags,消...
消息如何保障100%的投递成功? 什么是生产端的可靠性投递? 1、保障消息的成功发出 2、保障MQ节点的成功接收 3、发送端收到MQ节点(Bro...
消费者如何分配分区就是指某个topic,其N个分区和消费该topic的若干消费者群组下M个消费者的关系。如下图所示,C0和C1两个消费者如何分配...
应大部分的小伙伴的要求,今天这篇咱们用大白话带你认识 Kafka。 Kafka 基础 消息系统的作用 大部分小伙伴应该都清楚,这里用机油装箱举个...
什么是Kafka Kafka是一款分布式消息发布和订阅系统,它的特点是高性能、高吞吐量。 最早设计的目的是作为LinkedIn的活动流和运营数据...
我们知道经典的CAP理论中,在p无可避免的情况下,可用性和一致性只能保证一个,那么kafka是ap还是cp的呢? 其实它是可以根据配置所调整的,...