Kafka是一个开源的分布式流式数据平台，也成为分布式消息队列。

用于高吞吐量、低延迟的数据发布和订阅。

1、什么是topic (主题) ?

在Kafka中，Topic（主题）是数据发布和订阅的基本单位，它代表了相同类型的消息流。

一个Topic可以看作是一个逻辑上的数据流管道，消息的生产者（Producer）将消息发布到Topic中，而消息的消费者（Consumer）从Topic中订阅并接收消息。

Topic将消息按照一定的规则进行分区（Partition），每个分区包含了有序的消息序列。

以下是一些关于Kafka Topic的概念：

名称：每个Topic都有一个唯一的名称，用于标识和区分不同的主题。

2、什么是分区（partition） ?

分区：Topic可以被分为一个或多个分区，每个分区是一个有序的消息队列。

为什么要设置分区？

在Kafka中，对Topic进行分区的主要目的是：

实现数据的并行处理、提高系统的吞吐量和可伸缩性。

• 并行处理：通过将Topic划分为多个分区，Kafka可以实现消息的并行处理。每个分区都是一个有序的消息队列，可以独立地进行读取和写入操作。这样可以将消息的处理负载均衡到多个消费者上，提高整个系统的并发处理能力。

• 水平扩展：分区机制使得Kafka可以通过增加分区来水平扩展系统的吞吐量和容量。当系统的负载增加时，可以通过增加分区数量来分摊负载，使得每个分区上的消息处理压力减轻，从而提高整体的处理能力。

3、什么是副本（replica）?

副本：每个分区可以配置多个副本（Replica）.

为什么要设置副本？

副本用于提供数据冗余和高可用性。Kafka使用分布式的副本机制来保证数据的可靠性和容错性。

4、什么是偏移量（offset）？

偏移量（Offset）：每个消息在分区中都有一个唯一的偏移量，用于标识消息在分区中的位置。

消费者可以根据偏移量来定位和消费消息。

5、什么是消息保留策略？

保留策略：Topic可以配置一个保留策略（Retention Policy），用于控制消息在Topic中的保留时间。

根据保留策略，可以设置消息在Topic中的最大保留时间或者保留的消息数量。