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