Spring Boot 构建应用——整合消息中间件 Kafka

Kafka 是消息中间件的一种，消息中间件的工作过程可以用生产者 (Producer) -消费者 (Consumer) 模型来表示。生产者发消息到消息队列 (broker) 中去，消费者监听指定的消息队列，并且当消息队列收到消息之后，接收消息队列传来的消息，并且给予相应的处理。消息队列常用于分布式系统之间互相信息的传递。 Kafka 的架构图如下：



一个Topic (主题) 类似新闻中的体育、教育等分类概念，在实际工程中通常一个业务一个主题。一个 Topic 中的消息数据按照多个分区组织，Partition (分区) 是 Kafka 消息队列组织的最小单位，一个分区可以看作一个 FIFO 的队列。