首先生产者线程main生成消息后调用send方法，然后会经过拦截器、序列化器、分区器（Partition），分区器会对消息进行分区放入不同的本地队列，本地队列保存在计算机的内存中，每个队列32m，每16k数据形成一批消息；...

将服务器的 ACK 级别设置为-1，可以保证 Producer 到 Server 之间不会丢失数据，即 At Least Once 语义；

由于在 cli 模式下启动，停止 kafka 和zookpeer 进程命令行比较繁琐，所以推荐使用supervisor 来对进程进行管理。

使用 php producer.php 执行文件成功后，发现不能在消费者终端接到数据。 经过调试，发现在代码结尾加上 sleep(3) 消费者终端可以接收到数据。

kafka是一个分布式消息队列。具有高性能、持久化、多副本备份、横向扩展能力。生产者往队列里写消息，消费者从队列里取消息进行业务逻辑。一般在架构设计中起到解耦、削峰、异步处理的作用。 Kafka安装配置...

～ 本篇内容包括：RabbitMQ 消息分发模型、RabbitMQ 消息分发模型实现、RabbitMQ 手动消息确认

redis是一个键值型数据库，往往用于缓存热点数据，计数器，发布订阅，排行榜，分布式锁等场景

MessageQueue：消息队列。先进先出管理邮件。当Looper对象初始化时，将创建与其关联的MessageQueue；

kafka 是一款基于发布订阅的消息系统，Kafka的最大的特点就是高吞吐量以及可水平扩展， Kafka擅长处理数据量庞大的业务，例如使用Kafka做日志分析、数据计算等。...

mq 就是消息队列（Message Queue）。想必大家对队列的数据结构已经很熟悉了，消息队列可以简单理解为：把要传输的数据放在队列中，mq 就是存放和发送消息的这么一个队列中间件。在消息队列中，把数据放到消息队列的角色叫做 生产...