联系方式➡

Java 技术栈

基于Spring Framework 家族体系,结合Java最新特性,从实际的项目出发去剖析“What、Why、How”这三个问题。

Elastic Stack

基于Elasticsearch、Logstash 、Kibana、Beats 等对大数据进行分析,主要分享Elasticsearch

最新博客

Kafka Controller 模块(一)概述

作者 Siran 发表于 2020年6月6日

概述 在 Kafka 集群中会有一个或多个 broker,其中有一个 broker 会被选举为控制器(KafkaController),它负责管理整个集群中所有分区和副本

继续阅读

Kafka 副本模块 ReplicaManager

作者 Siran 发表于 2020年6月1日

Kafka 的 Replication Mechanism 是为了保证 Kafka 的高可用性,也就是说一个每个分区可以有多个副本,并且会其副本集合中(AR) 选出一个副本作为 Leader 副本,所有的读写请求都由选举出来的 Leader 副本处理

继续阅读

Kafka 时间轮 Java 版本实现

作者 Siran 发表于 2020年5月14日

概述 用Java 简单实现了 Kafka 中的时间轮。具体文章请看 Kafka 延迟操作(一)DelayedOperationPurgatory 具体实现 时间轮实现 public class TimingWheel

继续阅读

Kafka 延迟操作(二)DelayedProduce

作者 Siran 发表于 2020年5月7日

Kafka Producer ack 设置为 all,需要所有的ISR 都接收到这条消息后才会返回。这里就用到了延迟操作。

继续阅读