消息队列-Kafka

常见的消息队列,有RabbitMQ、RocketMQ、ActiveMQ、Kafka、ZeroMQ、MetaMq等，部分数据库缓存中间件如Redis也可实现消息队列的功能。
我对kafka的了解比较多一点,我们来了解一下kafka的机制和原理;

Kafka 是一种高吞吐量、分布式、基于发布/订阅的消息系统，最初由 LinkedIn 公司开发，使用

Scala 语言编写，目前是 Apache 的开源项目.它的实现底层是基于zookeeper的,zk上保存着集群的broker,topic,partion这些数据,还负责broker的故障发现,partition leader 选举，负载均衡等功能

先上一张图:

这张图可以清楚的表示出各个组成部分:消息的生产者,消费者,broker,topic,partion和zk的作用;

broker:可以理解为部署了KAFKA的服务器,负责消息的存储和转发;

topic:主要用于区分消息的类别,对消息进行分类,消费者通过监听指定的topic来获取消息;

消息队列-Kafka最先出现在Python成神之路。