Blogs

Kafka Controller 模块(一)概述

作者 Siran | 5400字 | 阅读大约需要11分钟 | 归档于消息队列

2020年6月6日

继续阅读

Kafka 副本模块 ReplicaManager

作者 Siran | 6700字 | 阅读大约需要14分钟 | 归档于消息队列

2020年6月1日

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

继续阅读

Kafka 时间轮 Java 版本实现

作者 Siran | 1300字 | 阅读大约需要3分钟 | 归档于消息队列

2020年5月14日

继续阅读

Kafka 延迟操作(二)DelayedProduce

作者 Siran | 2100字 | 阅读大约需要5分钟 | 归档于消息队列

2020年5月7日

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

继续阅读

Kafka 延迟操作(一)DelayedOperationPurgatory

作者 Siran | 3800字 | 阅读大约需要8分钟 | 归档于消息队列

2020年5月7日

继续阅读

Kafka 日志模块(四)LogManager

作者 Siran | 9900字 | 阅读大约需要20分钟 | 归档于消息队列

2020年5月5日

Kafka 的所有的消息都是通过日志来存储的,它是通过 LogManager 来进行初始化的,Log 类是真正操作日志的,LogManager 是用来管理 Log 的。

继续阅读

Kafka 日志模块(三)索引

作者 Siran | 4600字 | 阅读大约需要10分钟 | 归档于消息队列

2020年5月3日

继续阅读

Kafka 日志模块(二)LogSegment

作者 Siran | 2400字 | 阅读大约需要5分钟 | 归档于消息队列

2020年5月3日

继续阅读

SkyWalking(二)SkyWalkingAgent 初始化

作者 Siran | 1400字 | 阅读大约需要3分钟 | 归档于Skywalking

2020年5月2日

继续阅读

Skywalking(一)OpenTracing

作者 Siran | 2300字 | 阅读大约需要5分钟 | 归档于Skywalking

2020年5月2日

SkyWalking 是 google 发表的 OpenTracing 标准的实现之一。

继续阅读