Kafka架构支持命令行操作用于生产与消费数据的处理，并具备保存机制和拦截器功能

Kafka

一、消息队列技术应用

常规的消息传输机制，即由A向B进行信息传递，容易引发以下问题：

接收方B出现故障时，发送方A无法获知此状况，仍会持续发送数据内容

发送方A的数据传输速率与接收方B的处理速度需维持同步状态

1 消息队列模式

在引入消息队列机制后，A将数据传输至消息队列，随后由消息队列根据预设的发送方式将数据传递至B。

发送方式主要包含以下两种：

点对点模式，即一对一通信，由接收方主动获取数据
接收端B需启动一个用于实时监控消息队列的线程，以检查是否存在待处理的数据，并根据自身需求控制数据拉取的速度。需要注意的是，在数据被消费完成后，应立即从队列中删除，不保留任何历史记录。

发布/订阅者模式，即一对多通信，由消息队列主动将数据推送给目标端
该方式能够同时向多个客户端发送信息，无需为监控消息队列单独设置线程。

2 消息队列优点

解耦 --A与B之间可进行调整，但需遵循相同的接口规范

冗余 --消息队列能够实现数据的持久化存储，直至数据被完整处理

扩展性 --通过解耦实现

灵活