topic不存在精品文章

• 

  kafka

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

  W4n9Hu1 2019-07-30 18:35 評論0 收藏0
• 

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

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

  gself 2019-08-16 16:17 評論0 收藏0
• 

  個推基于 Apache Pulsar 的優(yōu)先級隊列方案

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

  bingchen 2019-07-24 10:53 評論0 收藏0
• 

  rocketmq簡介

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

  chnmagnus 2019-08-19 11:13 評論0 收藏0
• 

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

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

  seasonley 2019-08-15 12:23 評論0 收藏0
• 

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

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

  tainzhi 2021-11-23 09:51 評論0 收藏0