kafka原理和源码分析 - 文集

30篇文章 · 38551字 · 9人关注

Kafka源码分析-Server-日志存储(5)-LogSegment
为了防止Log文件过大，将Log切分成多个日志文件，每个日志文件对应一个LogSegment。在LogSegment中封装一个FileMessa...

0.2 493 0 1
Kafka源码分析-Server-日志存储(4)-OffsetIndex
为了提升查找消息的性能，从Kafka0.8开始，为每个日志文件添加了对应的索引文件。OffsetIndex对象对应磁盘管理上的一个索引文件，与上...

0.2 753 0 1

Kafka源码分析-Server-日志存储(3)-ByteBufferMessageSet
ByteBufferMessageSet分析介绍完生产者和消费者对压缩消息的处理过程，我们回到服务端，开始对ByteBufferMessage...

0.2 363 0 1
Kafka源码分析-Server-日志存储(2)-ByteBufferMessageSet
MessageSet的另一个子类是ByteBufferMessageSet,FileMessageSet.append()方法的参数就是这个类的...

0.2 435 0 1
Kafka源码分析-Server-日志存储(1)
基本概念 Kafka使用日志文件的方式保存生产者发送的消息。每条消息都有一个offset值来表示它在分区的偏移量，这个offset值是逻辑值，并...

0.2 951 0 1
Kafka源码分析-Server-api层
由Kafka网络层我们知道，Handler线程会取出Processor线程放入RequestChannel的请求进行处理，并将产生的响应通过Re...

0.5 307 0 2
Kafka源码分析-Server-网络层（2）
RequestChannel Processor线程与Handler线程之间传递数据是通过RequestChannel完成的。在RequestC...

0.3 715 0 1

Kafka源码分析-Server-网络层（1）
AbstractServerThread Acceptor和Processor都继承了AbstractServerThread，Abstract...

0.3 395 0 1
Kafka源码分析-Consumer（12）--源码经验总结
1.如何不用锁保证“线程封闭”，即一个线程单独占用一个对象？ KafkaConsumer<K, V>用的就是“线程封闭”，实现方法是使用原子类型...

0.4 701 0 2