启动zookeeper

1
2

$ bin/zkServer.sh start conf/zoo.cfg &
$ bin/zkCli.sh   

启动Kafka

我们启动两个实例：

1
2
3

$ bin/kafka-server-start.sh -daemon config/server.properties
$ bin/kafka-server-start.sh -daemon config/server-1.properties  

Kafka是基于partition的模型，在消费的时候，消费者会和kafka建立一个绑定的关系。假设有一个topic有3个partition：P1,P2,P3,同时有一个消费group对应有3个消费者:C1，C2，C3，则消费会建立一个P1-C1,P2-C2,P3-C3的关系。

kafka的文件系统

我们知道Kafka是一个Topic下有多个partition，具体结构如下：

下面我们就探究下Kafka的partition的组成到底是什么。

几个概念

broker：集群中的每一台服务器，称为Broker

topic或者subject:队列名

partition：一个队列中的消息可以存储到多台broker上面，一个broker中的分区，称为partition