RocketMQ有一個(gè)對其擴(kuò)展的開源項(xiàng)目incubator-rocketmq-externals特铝,這個(gè)項(xiàng)目中有一個(gè)子模塊叫“rocketmq-c...
![240](https://upload.jianshu.io/collections/images/1830483/%E5%BE%AE%E4%BF%A1%E6%88%AA%E5%9B%BE_20191031172325.png?imageMogr2/auto-orient/strip|imageView2/1/w/240/h/240)
RocketMQ有一個(gè)對其擴(kuò)展的開源項(xiàng)目incubator-rocketmq-externals特铝,這個(gè)項(xiàng)目中有一個(gè)子模塊叫“rocketmq-c...
RabbitMQ集群架構(gòu)模式 主備模式 實(shí)現(xiàn)RabbitMQ的高可用集群慨仿,一般在并發(fā)和數(shù)據(jù)量不高的情況下所坯,這種模式非常的好且簡單。主備模式也稱為...
kafka重復(fù)消費(fèi)的根本原因就是“數(shù)據(jù)消費(fèi)了锋八,但是offset沒更新”浙于!而我們要探究一般什么情況下會導(dǎo)致offset沒更新? max.poll....
“持久化”可以提高RabbitMQ的可靠性挟纱,以防在異常情況(重啟羞酗、關(guān)閉、宕機(jī)等)下的數(shù)據(jù)丟失樊销。RabbitMQ的持久化分為三個(gè)部分:交換器的持久...
1 Producer 一個(gè)應(yīng)用盡可能用一個(gè)Topic,消息子類型用tags來標(biāo)識整慎,tags可以由應(yīng)用自由設(shè)置 只有發(fā)送消息設(shè)置了tags,消...
消息如何保障100%的投遞成功? 什么是生產(chǎn)端的可靠性投遞围苫? 1裤园、保障消息的成功發(fā)出 2、保障MQ節(jié)點(diǎn)的成功接收 3剂府、發(fā)送端收到MQ節(jié)點(diǎn)(Bro...
消費(fèi)者如何分配分區(qū)就是指某個(gè)topic拧揽,其N個(gè)分區(qū)和消費(fèi)該topic的若干消費(fèi)者群組下M個(gè)消費(fèi)者的關(guān)系。如下圖所示腺占,C0和C1兩個(gè)消費(fèi)者如何分配...
應(yīng)大部分的小伙伴的要求淤袜,今天這篇咱們用大白話帶你認(rèn)識 Kafka。 Kafka 基礎(chǔ) 消息系統(tǒng)的作用 大部分小伙伴應(yīng)該都清楚衰伯,這里用機(jī)油裝箱舉個(gè)...
什么是Kafka Kafka是一款分布式消息發(fā)布和訂閱系統(tǒng)铡羡,它的特點(diǎn)是高性能、高吞吐量意鲸。 最早設(shè)計(jì)的目的是作為LinkedIn的活動流和運(yùn)營數(shù)據(jù)...
我們知道經(jīng)典的CAP理論中烦周,在p無可避免的情況下,可用性和一致性只能保證一個(gè)怎顾,那么kafka是ap還是cp的呢读慎? 其實(shí)它是可以根據(jù)配置所調(diào)整的,...