CallStub相关调用入口share/vm/runtime/stubRoutines.hpp // Calls to Java SimonNote: 函数指针结合typedef类型定义 typedef void (*CallStub)( address link, intptr_t* result, BasicType result_type, Method* metho

offset range 查询我们在实际使用过程中经常需要查询某个topic的某分区的offset的range命令行： kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list xxxx:9092 -topic xxxtopic --time -2 kafka-run-class.sh kafka.tools.GetOf

消息写入生产消息时的rpc请求日志leader节点 [2019-09-25 19:40:22,266] INFO Handling request:RequestHeader(apiKey=FETCH, apiVersion=5, clientId=broker-0-fetcher-0, correlationId=8855) -- {replica_id=0,max_wait_ti

MetadataCache什么时候更新updateCache方法用来更新缓存的。 发起线程 controller-event-threadcontroller选举的时候 CLASS_NAME METHOD_NAME LINE_NUM kafka/controller/KafkaController sendUpdateMetadataRequest 1043

几个概念的解释 LEO 日志的结尾位置，也是最后写入(append)消息的位置+1。这个位置不代表消费者能看到，仅仅表示单机的日志写入位置，因为要考虑其他副本的写入情况。leader与follower都有此指标。 HW high water mark的简称，对外公开的消费者的非事务消息(即未提交读模式)的位置。这个值的更新过程比较复杂。leader与follower都有此指标。与LEO的区别参见这

消费消息的请求(按序) org/apache/kafka/common/requests/RequestHeader org/apache/kafka/common/requests/ApiVersionsRequest org/apache/kafka/common/requests/MetadataRequest 批量查询topic的元数据信息 org/apache/kafka/

Object name的语法 形似 com.sun.someapp:type=Whatsit,name=25 com.sun.someapp 是domain，冒号后面的是key-property-list，每组kv的顺序随意，但是不能有空格，空格字符有特殊含义，不能有冒号。domain名不能含有冒号，不能含有/。 key-property-list中的key支持和？somedomain:t

nio基本处理逻辑查看这里 Selector的处理Selector实例构建NioEventLoop.openSelector()方法先用JDK API构建出来的Selector再用反射将其中的selectedKeys、publicSelectedKeys替换成他优化过的SelectedSelectionKeySet实例。JDK API构建出来的Selector 代码： // NioEven