在内网环境中，超时问题，网络表示这个锅我不背。经过这次漫长的排查过程，对网络抓包、TCP滑动窗口、Netty线程模型的理解更加深刻了。

本文详细介绍一个新的消费组在启动时从何处开始消费，并信息介绍了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...

为了充分揭示mycat读写分离、写节点挂掉后的自主切换、路由解析等原理，先搭建mycat测试环境，架构如下：1、源码安装 mysql安装Linux编译等基础软件yum -y install gcc gcc-c++ ncurses-devel pcre pcre-devel openssl openssl-devel安装cmakecmake安装包下载地址：http...

通过前面文章详解，我们知道Dubbo服务消费者标签dubbo:reference最终会在Spring容器中创建一个对应的ReferenceBean实例，而ReferenceBean实现了Spring生命周期接口：InitializingBean，接下来应该看一下其afterPropertiesSet方法的实现。1、源码分析ReferenceBean#afterPropertiesSetRe...

1、Druid解析引擎概要DruidSQL解析引擎主要分为三个部分，AST抽象语法树，词法解析，语法解析。AST抽象语法树，语法解析的结果，由众多AST语法对象组成一颗树，而词法分析就是解析出一个一个关键字，作为语法解析的输入。Druid SQL解析引擎整体介绍，推荐一篇文章：http://www.tuicool.com/articles/NNJNbmF故本节重点认识一下...

打破思维惯性，异步发送也能保证顺序性语义？

30张图，深入剖析kafka重平衡机制，从架构角度思考重平衡相关协议变更是如何有效避免重平衡。