Kafka数据模型

Topic

Kafka每条消息都必须属于一个主题；

Partition

每个主题可以分为多个分区，每个分区是一个有序队列；

每个分区允许Kafka集群对消息进行并行处理，提高吞吐量和可扩展性；

分区中每条消息都有一个offset，标识消息在分区中的位置；

Producer

生产者将消息发布到指定主题，可以选择性地指定消息发送到指定分区；

Consumer

消费者可以订阅一个或多个主题，从指定主题地一个或多个分区消费消息；

Consumer Group

消费者组内消费者共同消费主题的消息，每条消息只会被消费者组内的一个消费者消费；

Broker

天然分布式？

一台Kafka服务器叫做Broker，一个Topic分为多个partition，实际上partition会分布在不同的broker中；

生产者往一个topic里丢数据，实际上数据会在partition中，partition会分布在不同的broker上；