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