分布式消息系统 Kafka
主讲：Reythor 雷
2
Kafka
Kafka
2.1
对于 Kafka 基本原理的介绍，可以通过对以下基本术语的介绍进行。
2.1.1 Topic
主题。在 Kafka 中，使用一个类别属性来划分消息的所属类，划分消息的这个类称为 topic。
topic 相当于消息的分类标签，是一个逻辑概念。
2.1.2 Partition
分区。topic 中的消息被分割为一个或多个 partition，其是一个物理概念，对应到系统上
就是一个或若干个目录。
2.1.3 segment
段。将 partition 进一步细分为了若干的 segment，每个 segment 文件的最大大小相等。
2.1.4 Broker
Kafka 集群包含一个或多个服务器，每个服务器节点称为一个 broker。
一个 topic 中设置 partition 的数量是 broker 数量的整数倍。
2.1.5 Producer
生产者。即消息的发布者，其会将某 topic 的消息发布到相应的 partition 中。
2.1.6 Consumer Group
消费者。可以从 broker 中读取消息，其是以 consumer group 的形式出现的。
consumer group 是 kafka 提供的可扩展且具有容错性的消费者机制。组内可以有多个消
费者，它们共享一个公共的 ID，即 group ID。组内的所有消费者会协调在一起平均消费订阅
主题的所有分区。
Kafka 可以保证在稳定状态下，一个 partition 中的消息只能被同一个 consumer group 中
的一个 consumer 消费，而一个组内 consumer 只会消费某一个或几个特定的 partition。当然，
一个消息可以同时被多个 consumer group 消费。
