分布式系统进阶

62 篇文章
10 人订阅

全部文章

扫帚的影子

KafkaBridge - Kafka Client SDK 开源啦~~~

KafkaBridge 封装了对Kafka集群的读写操作,接口极少,简单易用,稳定可靠,支持c++/c、php、python、golang等多种语言,并特别针对...

231
扫帚的影子

利用Mesos构建多任务调度系统

1135
扫帚的影子

Kafka Mirror Maker 使用和图解

1014
扫帚的影子

Folly库编译官方说的相关依赖开始编译

1093
扫帚的影子

FBString分析与使用FBString简介

简单来说,使用了三层存储策略+内存分配策略+大小端支持,特别是配合使用 jemalloc, 减少磁盘碎片,加快并发下的分配速度和性能。

502
扫帚的影子

Kafka源码分析-网络层-1

592
扫帚的影子

BGP科谱

441
扫帚的影子

Kafka源码分析-网络层-3

上面的id即为我们在上篇介绍的非常重要的ConnectionId; (2) connect: 使用nio的SocketChannel连接到给定的地址,并且注册...

582
扫帚的影子

Kafka的Request和Response

每个Request和Response都由RequestHeader(ResponseHeader) + 具体的消费体构成;

592
扫帚的影子

Kafka源码分析-网络层-2

这里面最主要的就是accept(key, processors(currentProcessor)) (4) accept: 设置新连接socket的参数后交...

651
扫帚的影子

Kafka源码分析-启动流程

使用getPropsFromArgs方法来获取各配置项, 然后将启动和停止动作全部代理给KafkaServerStartable类;

680
扫帚的影子

Kafka基础组件和辅助类库简介

641
扫帚的影子

Kafka源码分析-配置文件

作为Class KafkaConfig的伴生类,定义了创建KafkaConfig对象的工厂方法:

601
扫帚的影子

Kafka初始化流程与请求处理

682
扫帚的影子

KafkaController分析2-NetworkClient分析InFlightRequests类

531
扫帚的影子

KafkaController分析7-启动流程

741
扫帚的影子

KafkaController分析6-Replica状态机

782
扫帚的影子

KafkaController分析3-ControllerChannelManager

使用NetworkClient连接到broker node, 使用selector处理网络IO;

531
扫帚的影子

KafkaController分析4-Partition选主

391
扫帚的影子

KafkaController分析5-Partition状态机

851

扫码关注云+社区