一、响应式流是什么? Reactive Streams 是 2013 年底由 Netflix、Lightbend 和 Pivotal(Spring 背后的公司)的工程师发起的...
一、响应式流是什么? Reactive Streams 是 2013 年底由 Netflix、Lightbend 和 Pivotal(Spring 背后的公司)的工程师发起的...
一、前言 响应式编程是啥? 为啥要有响应式编程? 响应式流的核心机制是什么? Spring 响应式编程能解决我们平时开发的什么痛点? Spring 响应式编程有哪些应用场景?...
一、前言 在如今的分布式环境时代,任何一款中间件产品,大多都有一套机制去保证一致性的,Kafka 作为一个商业级消息中间件,消息一致性的重要性可想而知,那 Kafka 如何保...
一、前言 在如今的分布式环境时代,任何一款中间件产品,大多都有一套机制去保证高可用的,Kafka 作为一个商业级消息中间件,消息可靠性的重要性可想而知,那 Kafka 如何保...
一、前言 上一篇我们讲了 聊聊 Kafka:Kafka 消息丢失的场景以及最佳实践[https://blog.csdn.net/riemann_/article/detail...
一、前言 大家好,我是老周,有快二十多天没有更新文章了,很多小伙伴一直在催更。先说明下最近的情况,最近项目上线很忙,没有时间写,并且组里有个同事使用 Kafka 不当,导致线...
一、前言 上一篇我们说了 腾讯一面:说一说 MySQL 中索引的底层原理[https://blog.csdn.net/riemann_/article/details/123...
一、前言 上周老周的一个好朋友让我出一篇教你读懂 SQL 执行计划,和我另一位读者反馈的面试题如何排查慢 SQL 的强相关,索性先出一篇一文读懂 MySQL Explain ...
一、前言 最近有很多读者要我出一些面试题的文章,一般我会给他一个老周整理的电子书,但有些读者反馈回来的面试题我觉得还是蛮经典的,而老周又在写系列的文章,本着对读者负责的态度,...
一、环境准备 老周这里编译 Pulsar 的版本是 2.9.1,也是 Pulsar 目前最新的版本。 JDK:1.8.0_241 Maven:3.6.1 Pulsar:apa...
一、集群搭建要求 1.1 搭建设计 搭建 Pulsar 集群至少需要 3 个组件:ZooKeeper 集群、Bookkeeper 集群和 Broker 集群(Broker 是...
一、环境准备 jdk下载地址链接:jdk 1.8[https://pan.baidu.com/s/1r7Ivzk0226wgpN31yxLvHw],提取码: dv5hpuls...
一、Pulsar 介绍 Apache Pulsar 是 Apache 软件基金会的顶级项目,是下一代云原生分布式消息流平台,集消息、存储、轻量化函数式计算为一体,采用计算与存...
一、前言 我们上一篇聊了 Rebalance 机制,相信你对消费组的重平衡有个整体的认识。这里再简单回顾一下,Rebalance 就是让一个 Consumer Group 下...
一、前言 我们上一篇分析了 Consumer 如何加入 Consumer Group,其实上一篇是一个很宏观的东西,主要讲 ConsumerCoordinator 怎么与 G...
一、安装 iTerm2 iTerm2 官网[https://iterm2.com/] 二、安装 oh-my-zsh 2.1 安装 2.2 卸载 oh-my-zsh 安装成功效...
一、前言 今天这一篇我们来说一下 Consumer 是如何加入 Consumer Group 的,我们前面有一篇 Kafka 的架构文章有说到,Consumer 有消费组(C...
一、Consumer 的使用 Consumer 的源码解析主要来看 KafkaConsumer,KafkaConsumer 是 Consumer 接口的实现类。KafkaCo...
一、Producer 的网络模型 我们前面几篇有说 Producer 发送流程的源码分析,但那个是大的轮廓,涉及到发送很多相关的内容,比如: 获取 topic 的 metad...