联系方式➡
基于Spring Framework 家族体系,结合Java最新特性,从实际的项目出发去剖析“What、Why、How”这三个问题。
基于Elasticsearch、Logstash 、Kibana、Beats 等对大数据进行分析,主要分享Elasticsearch
阅读更多
作者 Siran 发表于 2020年6月6日
概述 在 Kafka 集群中会有一个或多个 broker,其中有一个 broker 会被选举为控制器(KafkaController),它负责管理整个集群中所有分区和副本
继续阅读
作者 Siran 发表于 2020年6月1日
Kafka 的 Replication Mechanism 是为了保证 Kafka 的高可用性,也就是说一个每个分区可以有多个副本,并且会其副本集合中(AR) 选出一个副本作为 Leader 副本,所有的读写请求都由选举出来的 Leader 副本处理
作者 Siran 发表于 2020年5月14日
概述 用Java 简单实现了 Kafka 中的时间轮。具体文章请看 Kafka 延迟操作(一)DelayedOperationPurgatory 具体实现 时间轮实现 public class TimingWheel
作者 Siran 发表于 2020年5月7日
Kafka Producer ack 设置为 all,需要所有的ISR 都接收到这条消息后才会返回。这里就用到了延迟操作。
Copyright ©️ 2020, siran all rights reserved.
苏ICP备20005919号
模板来自 Bootstrapious. 移植到 Hugo 来自 DevCows.