kafka在0.11之后,开始支持幂等发送和事务,那么分别是如何实现的呢? 幂等发送引入producerid +s...[作者空间]
kafka的存储层主要包含 分区,副本,日志,日志分段这些概念,以问答的形式来描述 1.为什么kafka的每一个主...[作者空间]
主消费者负责计算分区的分配,将结果发送给协调者。所有消费者从协调者处获取自己的分区信息。每个消费者需要发送两种请求...[作者空间]
1.发布-订阅模式 TOPIC同一条消息会被多个消费组消费,每个消费组设置一个消费者,以此实现广播。 2.队列模式...[作者空间]
高性能包含两个方向写的高性能1)顺序写+page cache2)生产者批量发送消息集,压缩:生产者并不直接将消息发...[作者空间]