首先,明确几个概念：

(1) Kafka运行在一个或多个服务器上,每个服务器被称为Broker，主要用于存储消息，但不需要维护offset偏移量。

(2) Kafka集群分类存储的记录流被称为主题(Topics)。

(3) 每个消息记录包含一个键，一个值和时间戳。

(4)（key与topic可以确定一个partition），此外可以通过制定partitioner分区器，进行计算到相关的分区节点上面，此外还可以通过相关的不同的算法进行设定。