Kafka分区状态机
1、分区状态 分区状态机用来负责集群下所有分区的状态管理，定义了 4 个状态 ，如下 ： NonExistent 分区不存在或己被删除。 NewPartKafka消息存储设计探索：高效稳定的数据存储之道
1、基本概念 主题 Topic，kafka中的消息以主题为基本单位来归类，各个主题逻辑上相互独立。 分区 Partition，每个主题又可以分为一个或多个分区，每Kafka原理与源码解析：处理Produce请求
生产者发送消息，kafka server 端在收到 Produce请求后，会由 KafkaApis 进行处理。 KafkaApis 是 server 端处理所有请kafka监控指标
1、系统指标 类型 java.lang:type=OperatingSystem 指标项 指标项说明 FreePhysicalMemorySize空闲物理
·
kafka
cat原理与源码分析
1、示例 来自官网的一段简单demo： public String quickstart() { // 开启了一个Transaction Transactionkafka配置参数整理
生产者 acks 控制着生产者发送消息后，要求 Kafka 服务器返回的确认（acknowledgment）级别。默认为1。 acks 参数可以设置为以下几个值：
·
kafka
Disruptor
1、背景 APM系统中的collector模块用来接收客户端上报的消息，如何提高collector的吞吐量是我们迫切关注的问题。 我们采用经典的异步消费模型来提升
·
待分类
RocksDB
1、是什么 是一个使用C++编写的嵌入式 KV 存储引擎。 是Facebook基于levelDB开发的。 2、特点 高性能 RocksDB使用一套日志结构的数
·
待分类
grafana
目录 [root@Server ~]# find / -name grafana /var/lib/grafana # 存储存储临时文件、会话和sq
·
待分类