消息组接到某项目组反馈，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重平衡机制，从架构角度思考重平衡相关协议变更是如何有效避免重平衡。

想必大家都看过笔者Kafka集群故障的排查经验，并通过优化参数使得Kafka集群应对洪峰流量的能力提升N倍，网卡流量几乎打满，集群写入稳如泰山，无独有偶，菜鸟的一个故障导致集群单个topic从5W/tps直接飙升到50W/tps,但集群稳如狗，相当于做了一次“突然的压测”，让我们一起回顾一下这次惊心动魄的过程吧。在进入本文的探讨之前，强烈推荐一下笔者最近的得意之作：Kafka集群中大部分消费组无端

温馨提示：整个 Kafka 专栏基于 kafka-2.2.1 版本。1、KafkaConsumer 概述根据 KafkaConsumer 类上的注释上来看 KafkaConsumer 具有如下特征：在 Kafka 中 KafkaConsumer 是线程不安全的。2.2.1 版本的KafkaConsumer 兼容 kafka 0.10.0 和 0.11.0 等低版本。消息偏...

1、初识 Kafka Producer 生产者2、源码分析 Kafka 消息发送流程(文末附流程图)3、KafkaProducer Sender 线程详解（含详细的执行流程图）4、初始 Kafka Consumer 消费者5、源码分析Kafka 消息拉取流程6、Kafka与RocketMQ性能对比大揭秘...

kafka系列第一篇，蕴含了笔者的学习方法，该系列将见证笔者从Kafka小白进阶专家之路，欢迎各位小伙伴关注，一起前行。