kafka消息分区机制

首先咱们来看下官网的图示，kafka分区的做用我的以为就是提供一种负载均衡的能力，或者说对数据进行分区的主要缘由，就是为了实现系统的高伸缩性（Scalability）。不一样的分区可以被放置到不一样节点的机器上，而数据的读写操做也都是针对分区这个粒度而进行的，这样每一个节点的机器都能独立地执行各自分区的读写请求处理。而且，咱们还能够经过添加新的节点机器来增长总体系统的吞吐量。java 分区策略 下

>>阅读原文<<