topic不存在精品文章

• 

  kafka

  ...a運(yùn)行在集群上，集群包含一個(gè)或多個(gè)服務(wù)器。kafka把消息存在topic中，每一條消息包含鍵值（key），值（value）和時(shí)間戳（timestamp）。 kafka有以下一些基本概念： Producer 消息生產(chǎn)者，就是向kafka broker發(fā)消息的客戶端。 Consumer 消息...

  W4n9Hu1 2019-07-30 18:35 評(píng)論0 收藏0
• 

  深度解析RocketMQ Topic的創(chuàng)建機(jī)制

  ...，下面我用一張圖來說明topic的存儲(chǔ)模型： 其實(shí)rocketmq中存在兩種不同的topic創(chuàng)建方式，一種是我剛剛說的預(yù)先創(chuàng)建，另一種是自動(dòng)創(chuàng)建，下面我開車帶大家從源碼的角度來詳細(xì)地解讀這兩種創(chuàng)建機(jī)制。 自動(dòng)創(chuàng)建 默認(rèn)情況下，to...

  gself 2019-08-16 16:17 評(píng)論0 收藏0
• 

  個(gè)推基于 Apache Pulsar 的優(yōu)先級(jí)隊(duì)列方案

  ...越來越多時(shí)，后面進(jìn)入的 task 消息會(huì)因?yàn)榍懊?task 消息還存在隊(duì)列情況而出現(xiàn)延遲。如下圖所示, 當(dāng) task1 消息量過大時(shí)，在task1 消費(fèi)結(jié)束前，taskN 將一直處于等待狀態(tài)。 Kafka 在 Topic 數(shù)量由 64 增長(zhǎng)到 256 時(shí)，吞吐量下降嚴(yán)重，Kaf...

  bingchen 2019-07-24 10:53 評(píng)論0 收藏0
• 

  rocketmq簡(jiǎn)介

  ...多，如一個(gè)生產(chǎn)方發(fā)布消息，需要多個(gè)消費(fèi)方訂閱，也會(huì)存在多個(gè)生產(chǎn)方生產(chǎn)消息，一個(gè)消費(fèi)方消費(fèi)消息，出現(xiàn)一對(duì)多，多對(duì)一的情況。 上圖就是擴(kuò)展了producer、consumer和Topic的概念模型，rocketmq最核心的概念就是Tpoic，producer和c...

  chnmagnus 2019-08-19 11:13 評(píng)論0 收藏0
• 

  分布式消息隊(duì)列 RocketMQ 源碼分析 —— Message 發(fā)送與接收

  ...r#createTopicKey} 對(duì)應(yīng)的 Topic發(fā)布信息。用于 Topic發(fā)布信息不存在 && Broker支持自動(dòng)創(chuàng)建Topic 14: this.mQClientFactory.updateTopicRouteInfoFromNameServer(topic, true, this.defaultMQProducer); 15: topicPub...

  seasonley 2019-08-15 12:23 評(píng)論0 收藏0
• 

  高并發(fā)異步解耦利器：RocketMQ究竟強(qiáng)在哪里？

  ...啟動(dòng)時(shí)創(chuàng)建，關(guān)閉時(shí)刪除，如果broker異常退出，則文件會(huì)存在，在下次啟動(dòng)時(shí)會(huì)走修復(fù)流程；checkpoint：檢查點(diǎn)，主要存放以下內(nèi)容：physicMsgTimestamp：commitlog文件最后一次落盤時(shí)間；logicsMsgTimestamp：consumequeue最后一次落盤時(shí)間；in...

  tainzhi 2021-11-23 09:51 評(píng)論0 收藏0