发简信
IP属地：浙江
降级与熔断 1.1、降级 降级也就是服务降级，当我们的服务器压力剧增，为了保证核心功能的可用性，可以选择性的降低一些功能的可用性，或者直接关闭该...
1、过期时间（TTL） 通过消息的timestamp字段和ConsumerInterface接口的onConsumer（）方法可实现消息的TTL...
1、文件目录布局 不考虑多副本的情况，一个分区对应一个日志（log）。为了防止log过大，Kafka还引入了日志分段（LogSegment）的概...
主题作为消息的归类，可以再细分为一个或多个分区，分区可以看作对消息的二级归类。分区的划分不仅为Kafka提供了可伸缩性、水平扩展的功能，还通过多...
//www.greatytc.com/p/aa0d4808cbb8 1、底层数据结构 hashmap的定义位于src/runtim...
1、消费者和消费者组 消费者负责订阅Kafka中的主题，并从订阅的主题中拉取消息。与其他消息中间件不同的是：Kafka中的消费理念中还有一层消费...
1、客户端开发 下面是构造的消息对象ProducerRecord. public class ProducerRecord<K,V>( p...
前言：切片的设计思想来源于动态数组，是为了开发者能更加方便地使用使一个数据结构能自动增加和减少，但是切片本身并不是动态数组。 1、切片与数组 G...
前言： Kafka虽然是基于磁盘做的数据存储，但却具有高性能、高吞吐、低延时的特点，其吞吐量动辄几万、几十上百万。总结起来大致就5个原因，顺序读...