1、Reactor反应堆设计模式1.1 单线程模型单线程模型Reactor(此图来源与网络)下面以java nio为基础，实现Reactor模型。Nio服务端代码：package threadmode.r1;import java.io.IOException;import java.net.InetSocketA...

HA主从同步的核心类图如图所示：1、初始RocketMQ HAHAService：主从同步核心实现类。1）AtomicInteger connectionCount：Master维护的连接数。（Slave的个数）。2）List connectionList：具体连接信息。3）AcceptSocketService acceptSocketService：服务端接收连接线程实...

本文详细介绍一个新的消费组在启动时从何处开始消费，并信息介绍了CONSUME_FROM_MAX_OFFSET、CONSUME_FROM_FIRST_OFFSET、CONSUME_FROM_TIMESTAMP其计算逻辑，解答CONSUME_FROM_MAX_OFFSET在什么情况下不生效并如何解决。

Netty是一款非常优秀的网络编程框架，是对NIO的二次封装，本文将重点剖析Netty服务端的启动流程，深入底层了解如何使用NIO编程服务端。本文是笔者基于问题的启发式源码阅读技巧的展示，建议带着如下问题开始本文的阅读：ServerBootstrap 的 option 与 childOption 分别有什么作用服务端IO通道如何绑定事件链。1、Netty服务端启动示例基于Netty的使用示例如下：

1、ElasticSearch Client详解2、Elasticsearch文档读写模型实现原理3、Elasticsearch Document Index API详解、原理与示例4、Elasticsearch Document Get API详解、原理与示例5、Elasticsearch Document Delete API详解、原理与示例6、Elasticsearch Docum...

消息组接到某项目组反馈，topic 在扩容后出现部分队列无法被消费者，导致消息积压，影响线上业务？考虑到该问题是发送在真实的线上环境，为了避免泄密，本文先在笔者的虚拟机中来重现问题。1、案情回顾1.1 集群现状集群信息如下：例如业务主体名 topic_dw_test_by_order_01 的路由信息如图所示：当前的消费者信息：broker 的配置信息如下：brokerClu...

本文是《跟我学Kafka：从零开始学习Kafka》,开启从小白到专家的进阶之旅。将对Kafka Consumer做一个简单的介绍，是深入研究Kafka Conumer的一扇窗。本文主要从如下三个方面展开：核心参数核心组件核心API1、Kafka Consumer核心参数览个人觉得，要想深入了解Kafka Consumer的核心工作机制可以从它的核心参数切入，为后续深入了解它的队列负载机制、消息拉取

相信大家最近一定关注到一款重量级消息中间件Kafka发布了2.8版本，并且正式移除了对Zookeeper的依赖，背后的设计哲学是什么呢？仅仅只是减少了一个外部依赖吗？答案显然不会这么简单，容我慢慢道来。在解答为什么之前，我觉得非常有必要先来阐述一下Zookeeper的经典使用场景。1、Zookeeper的经典使用场景zookeeper是伴随着大数据、分布式领域的兴起。大数据中的一个非常重要的议题是

无处不在的时间轮算法

源码分析是手段，通过源码分析提取消息拉取线程模型、核心参数核心运作机制是王道