- 限流削峰
- 异步解藕
- 数据收集
发布订阅模式其实分为两种方式：
- 发布：即推送，消息队列主动将消息推送给消费者（缺点：消费者处理不来，导致推送失败）
- 订阅：即拉去，消费者主动去消息队列中拉去数据（缺点：需要消费者不断轮询消息队列）
kafka是基于发布订阅者模式的消息队列。【订阅者模式，消费者主动拉去！】
基本架构- Producer：消息生产者
- Broker：节点，就是存储消息的一台台机器
- Topic：消息分类，同一种消息发送到同一个Topic中
- Partition：将同一个Topic分区进行负载均衡，生产者将消息轮询发不到不同Partition中
- Leader：主Topic
- Follower：从Topic，Leader的副本，Leader挂了Follower上（ISR），所以Leader和Follower不能在同一个机器中！
- Consumer：消息消费者
- Consumer Group：消费组，即相同功能的消费者。同一个消息被消费组中的任意一个消费者消费了就可以
- metadata：路由表
metadata信息包括了整个集群的每个topic的所有partition的信息！
- metadata特点
– Kafka的metadata是由zookeeper维护的（RecoketMQ的分布式实现是由内部的NameServer实现的）
– Broker定时从zookeeper中刷新最新的metadata就可
– 我们给Producer/Consumer客户端配置一个或多个Broker
– 这样Producer/Consumer客户端就可以获取整个集群的metadata信息
– 然后我们给Producer/Consumer客户端配置需要生产/消费的Topic后，kafka客户端就知道将消息发送到哪了/从哪获取！
