發(fā)簡(jiǎn)信
IP屬地：上海
-
源碼分析Kafka 消息拉取流程
本節(jié)重點(diǎn)討論 Kafka 的消息拉起流程。 @TOC １、KafkaConsumer poll 詳解 消息拉起主要入口為：KafkaConsum...
-
KafkaProducer Sender 線程詳解（含詳細(xì)的執(zhí)行流程圖）
溫馨提示：本文基于 Kafka 2.2.1 版本。 上文 《源碼分析 Kafka 消息發(fā)送流程》 已經(jīng)詳細(xì)介紹了 KafkaProducer s...
-
RocketMQ一個(gè)新的消費(fèi)組初次啟動(dòng)時(shí)從何處開始消費(fèi)呢？
1、拋出問(wèn)題 一個(gè)新的消費(fèi)組訂閱一個(gè)已存在的Topic主題時(shí)，消費(fèi)組是從該Topic的哪條消息開始消費(fèi)呢？ 首先翻閱DefaultMQPushC...
-
源碼分析RocketMQ消息軌跡
本文沿著《RocketMQ消息軌跡-設(shè)計(jì)篇》的思路，從如下3個(gè)方面對(duì)其源碼進(jìn)行解讀： 發(fā)送消息軌跡 消息軌跡格式 存儲(chǔ)消息軌跡數(shù)據(jù) 1、發(fā)送消息...
-
RocketMQ 消息發(fā)送system busy、broker busy原因分析與解決方案
1、現(xiàn)象 最近收到很多RocketMQ使用者，反饋生產(chǎn)環(huán)境中在消息發(fā)送過(guò)程中偶爾會(huì)出現(xiàn)如下4個(gè)錯(cuò)誤信息之一：1）[REJECTREQUEST]s...
-
Elasticsearch Query DSL之全文檢索(Full text queries)
本節(jié)將詳細(xì)介紹DSL全文搜索。全文查詢包括如下幾種模式： match query標(biāo)準(zhǔn)的全文檢索模式，包含模糊匹配、前綴或近似匹配等。 match...
-
Elasticsearch Search API之(Request Body Search 查詢主體)-下篇
?preference 查詢選擇副本分片的傾向性(即在一個(gè)復(fù)制組中選擇副本的分片值。默認(rèn)情況下，es以未指定的順序從可用的碎片副本中進(jìn)行選擇，副...
-
Elasticsearch Search API之(Request Body Search 查詢主體)-上篇
本節(jié)將詳細(xì)介紹es Search API的查詢主體，定制化查詢條件的實(shí)現(xiàn)主體。 query 搜索請(qǐng)求體中查詢條件使用es DSL查詢語(yǔ)法來(lái)定義。...
-
Elasticsearch Search API 概述與URI Search
?本節(jié)開始，將詳細(xì)介紹Search API的使用。 Search API概述 詳細(xì)API如下： public final SearchRespo...
個(gè)人介紹
《RocketMQ技術(shù)內(nèi)幕》作者，如果本文對(duì)您有幫助的話，歡迎關(guān)注“中間件興趣圈”公眾號(hào)。