您的位置:首页 > 其它

35:Kafka源码解读中分区数、Consumer并行度等

2016-07-11 10:48 615 查看
本期内容:
1 Kafka中分区深度解析
2 Consumer并行度深度解析

Partition.scala:
Kafka完成稿吞吐性,是由于:
1. 对顺序读写采用OS的page级别的缓存,而不是使用内存。
2. Topic partition进行分布式
KafkaServer:是一个NIO socket server。
KafkaController
partition会有目录。其中有log本身,以及
ReplicaManager
kafka-console-peoducer、kafka-console-consumer
从一个分区开始对生产、消费进行调试试验。
Partition.scala
KafkaProducer:partition、
consumer group中的  一个consumer可以消费一个Topic下的一个分区,也可以消费其它分区。
ConsumerIterator:makeNext、
SimpleConsumer:可以进行更细粒度的访问控制。fetch。
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: