1、Kafka 是一款消息引擎系统

消息引擎系统是一组规范。企业利用这组规范在不同系统之间传递语义准确的消息,实现松耦合的异步式数据传递。

Kafka 的消息编码格式是 二进制的字节序列

Kafka 支持的两种消息模型

  1. 点对点模型,系统 A 发送的消息只能被 B 系统消费,其他系统不能读取 A 系统发送的消息,一对一的关系。

  2. 发布 / 订阅模型,有 Topic(主题)、Producer(生产者)、Consumer(消费者)的概念,可能会存在多个 ProducerTopic 发送消息,也可能存在多个 Consumer 来消费消息,多对多的关系。

消息队列的优点:解耦异步削峰

0%