kafka学习笔记：知识点整理.docx_notpresentinmetadataafter60000ms.资源-CSDN文库

13 浏览量 2023-08-11 21:17:05 上传评论收藏 764KB DOCX 举报

资源推荐

资源详情

资源评论

kafka 学习笔记：知识点整理

一、为什么需要消息系统

1.解耦：

　　允许你独立的扩展或修改两边的处理过程，只要确保它们遵守同样的接口约

束。

2.冗余：

　　消息队列把数据进行持久化直到它们已经被完全处理，通过这一方式规避了

数据丢失风险。许多消息队列所采用的"插入-获取-删除"范式中，在把一个消息

从队列中删除之前，需要你的处理系统明确的指出该消息已经被处理完毕，从而

确保你的数据被安全的保存直到你使用完毕。

3.扩展性：

　　因为消息队列解耦了你的处理过程，所以增大消息入队和处理的频率是很容

易的，只要另外增加处理过程即可。

4.灵活性 & 峰值处理能力：

　　在访问量剧增的情况下，应用仍然需要继续发挥作用，但是这样的突发流量

并不常见。如果为以能处理这类峰值访问为标准来投入资源随时待命无疑是巨大

的浪费。使用消息队列能够使关键组件顶住突发的访问压力，而不会因为突发的

超负荷的请求而完全崩溃。

5.可恢复性：

　　系统的一部分组件失效时，不会影响到整个系统。消息队列降低了进程间的

耦合度，所以即使一个处理消息的进程挂掉，加入队列中的消息仍然可以在系统

恢复后被处理。

6.顺序保证：

　　在大多使用场景下，数据处理的顺序都很重要。大部分消息队列本来就是排

序的，并且能保证数据会按照特定的顺序来处理。（Kafka 保证一个 Partition

内的消息的有序性）

7.缓冲：

　　有助于控制和优化数据流经过系统的速度，解决生产消息和消费消息的处理

速度不一致的情况。

8.异步通信：

　　很多时候，用户不想也不需要立即处理消息。消息队列提供了异步处理机制，

允许用户把一个消息放入队列，但并不立即处理它。想向队列中放入多少消息就

放多少，然后在需要的时候再去处理它们。

二、kafka 架构

剩余16页未读，继续阅读

内容反馈

小小哭包

粉丝: 1899
资源: 3854

最新资源

资源上传下载、课程学习等过程中有任何疑问或建议，欢迎提出宝贵意见哦~我们会及时处理！点击此处反馈

feedback-tip