kafka不支持延迟消息，rocketmq支持的延迟消息粒度有限，pulsar（https://github.com/apache/pulsar）采用优先队列的方式实现，支持任意粒度的延迟消息，不过，对于大量延迟比较久的消息，内存消耗会比较严重。本文学习下如何在mac上...

通过这个命令我们可以做一个可视化的，展示前三百队列的情况，做到实时观察队列数据，如下图所示。

如上图，在不使用消息队列服务器的时候，用户的请求数据直接写入数据库，在高并发的情况下数据库压力剧增，使得响应速度变慢。但是在使用消息队列之后，用户的请求数据发送给消息队列之后立即 返回，再由消息队列的消费者进程从...

上篇文章说到，当leader宕机，这时候follower可以参与竞争leader，但不是所有follower都有资格，只有在ISR里面的follower副本才有资格，在0.9.0.0之前有两个参数，后面版本就一个超时时间，默认10s。Highwatermark 和 log end offs...

上篇文章说了，broker的消息设计，采用紧凑的byteBuffer，存储设计主要包含attribute后三个表示压缩类型，还有crc效验，以及key和value，后面新增了时间戳。...

上篇文章说了，触发rebalance是当消费者组订阅的topic数量发生改变，或者topic分区数量发生改变，或者consumer数量发生变化，比如新的consumer加入组，则会重平衡。还介绍了分区策略range，round-robin，sticky。Kafka监听。以及ka...

上篇文章说了，kafka位移提交通过enable.auto.commit控制手动提交还是自动提交，手动提交又分为异步提交和同步提交，还可以指定分区进行提交，默认是提交给所有分区。手动提交可以对应不同的业务场景，当需要业务全部处理完才...

上篇文章说了，sesstion.time.out 、max.poll.interval.ms、max.poll.records和auto.offset.reset等参数。

上篇文章说了，消息压缩可以看分情况进行，判断下服务器cpu空闲还是io空闲较多，如果cpu空闲较多，则考虑消息积压，反之则不考虑。还有消费者组，consumer group，对于同一个group，只会发送一条消息进入一个实例。位移提交在0.9.0.0...

上篇文章说了，acks，1代表什么都不管，即使配置了回调也不会起作用，0代表不会等待replic副本里的不会持久化，只要broker leader持久化成功则返回给producer。-1代表all，则表示全部持久化成功才返回成功给producer，Retries，batch...