Kafka日志段实现解析：日志段是Kafka存储消息的基本单元，由消息日志文件(.log)和三个索引文件(.index、.timeindex、txnindex)组成。每个日志段通过FileRecords保存消息，使用lazyOffsetIndex、lazyTimeIndex和txnIndex管理索引。

本文分析了Kafka日志加载日志段的核心机制。日志作为日志段的容器，主要通过LogAppendInfo、LogLog源码、RollParams等核心组件实现管理功能。日志段文件包含.log、.index等基础文件，以及.snapshot、.deleted等特殊用途文件。日志初始化流程包括创建分区路径、初始化LeaderEpoch缓存、加载日志段对象等关键步骤。其中LeaderEpoch检查点文件和

摘要：Spark存储系统负责管理内存和磁盘中的数据，包括Shuffle中间文件、RDD缓存和广播变量。核心组件BlockManager通过MemoryStore（基于LinkedHashMap结构）管理内存数据块元数据，DiskStore借助DiskBlockManager实现磁盘数据访问。Shuffle中间文件包含数据和索引文件，类似Kafka设计；RDD缓存提升计算效率；广播变量减少数据分发开

spring boot启动tomcat流程，网上已经很多，这里只是给自己以后看，总结，不好勿喷，谢谢.自动配置类流程：SpringBootApplication>>EnableAutoConfiguration>>org.springframework.context.support.AbstractApplicationContext#invokeBeanFactoryP

spring对bean的定义信息，大多数都放在BeanDefinition，它是一个接口，大多数的实现逻辑，都在AbstractBeanDefinition而RootBeanDefinition和GenericBeanDefinition都继承于它，但spring在处理BeanDefinition，还是用RootBeanDefinition，那GenericBeanDefinition是用来干嘛的

1、安装dockersudoapt install docker.io2、修改 cgroupdriver to systemdsudo vi /etc/docker/daemon.json添加以下内容：{"exec-opts": ["native.cgroupdriver=systemd"]}sudo systemctl daemon-reloadsudo systemctl restart do

去重指定字段

POST esindex/_doc/id/_update{"script" : "ctx._source.bussinesData.remark='test'",}es的restful接口UpdateRequest updateRequest = new UpdateRequest(dto.getEsIndex(), dto.getId());Map<String, Object> p

//查询前缀包含的内容POST /products/_search{"query": {"prefix": {"desc.keyword": {"value": "iP"}}}}POST /products/_search{"query": {"term": {"productID.keyword": "XHDK-A-1293-#fJ3"}}}//不查询为空的数据.

es的bool查询