kafka面试题(2020版)

kafka概述

什么是kafka?

kafka是一个分布式基于发布/订阅模式的消息队列(Message Queue),主要应用于大数据实时处理领域。

MQ传统应用场景之异步处理

使用MQ的好处

  1. 解耦
    允许你独立的扩展或修改两边的处理过程,只要遵守同样的接口约束
  2. 可恢复性
    系统的一部分组件失效不会影响整个系统
  3. 缓冲
    有助于控制和优化数据流经过系统的速度,解决生产者和消费者处理速度不一致的情况
  4. 灵活性&峰值处理能力
    能够使组件顶住突发的访问压力,而不会因为突发的超负荷请求而完全崩溃
    5.异步通信
    消息队列提供了异步处理机制,允许用户把一个消息放入队列中,但不立即处理。想向队列中放入多少消息就放入多少消息,然后在需要的时候再去处理

消息队列的两种模式

1)点对点模式

生产者生产消息到队列中,消费者主动拉取消息,消息被消费后从队列中消失 ,如果该消息需要给多个消费者,必须再放到新的队列中才行,消息不可复用。

2)发布/订阅模式

生产者将消息发布到(topic)队列中,同时有多个消费者(订阅)该消息。
这种模式又分为两种方式:
队列往外推消息
队列以一定速度,往外面推送消息,而消费者消费速度不一样,这样会造成消费速度过快的消费者浪费资源,消费速度过慢的消费者服务器崩溃
消费者拉去消息
这种方式,消费者消费的速度可以自己设置,但是需要轮询队列是否有新消息

kafka基础架构

本文地址:https://blog.csdn.net/weixin_44421869/article/details/110570936

(0)
上一篇 2022年3月21日
下一篇 2022年3月21日

相关推荐