发简信
IP属地：上海
-
源码分析Kafka 消息拉取流程
本节重点讨论 Kafka 的消息拉起流程。 @TOC １、KafkaConsumer poll 详解 消息拉起主要入口为：KafkaConsum...
-
KafkaProducer Sender 线程详解（含详细的执行流程图）
温馨提示：本文基于 Kafka 2.2.1 版本。 上文 《源码分析 Kafka 消息发送流程》 已经详细介绍了 KafkaProducer s...
-
RocketMQ一个新的消费组初次启动时从何处开始消费呢？
1、抛出问题 一个新的消费组订阅一个已存在的Topic主题时，消费组是从该Topic的哪条消息开始消费呢？ 首先翻阅DefaultMQPushC...
-
源码分析RocketMQ消息轨迹
本文沿着《RocketMQ消息轨迹-设计篇》的思路，从如下3个方面对其源码进行解读： 发送消息轨迹 消息轨迹格式 存储消息轨迹数据 1、发送消息...
-
RocketMQ 消息发送system busy、broker busy原因分析与解决方案
1、现象 最近收到很多RocketMQ使用者，反馈生产环境中在消息发送过程中偶尔会出现如下4个错误信息之一：1）[REJECTREQUEST]s...
-
Elasticsearch Query DSL之全文检索(Full text queries)
本节将详细介绍DSL全文搜索。全文查询包括如下几种模式： match query标准的全文检索模式，包含模糊匹配、前缀或近似匹配等。 match...
-
Elasticsearch Search API之(Request Body Search 查询主体)-下篇
preference 查询选择副本分片的倾向性(即在一个复制组中选择副本的分片值。默认情况下，es以未指定的顺序从可用的碎片副本中进行选择，副...
-
Elasticsearch Search API之(Request Body Search 查询主体)-上篇
本节将详细介绍es Search API的查询主体，定制化查询条件的实现主体。 query 搜索请求体中查询条件使用es DSL查询语法来定义。...
-
Elasticsearch Search API 概述与URI Search
本节开始，将详细介绍Search API的使用。 Search API概述 详细API如下： public final SearchRespo...