Kafka副本管理器 Broker 启动 Broker在启动时,会启动一个副本管理器,代码如下: def startup() { ... // 1、ReplicaManager创建 r 2024-07-15 · kafka MQ
使用JMeter接口测试教程 简介 JMeter是一个用于性能测试、负载测试和功能测试的开源工具,由 Apache 软件基金会开发和维护。 下载 官方网站:https://jmeter.apa 2024-07-10 · 测试
kafka副本状态机 1、副本状态 当前, Kafka 为副本定义了 7 种状态以及每个状态之间的流转规则。这些状态分别如下: NewReplica Controller 创建副 2024-07-09 · kafka MQ
Kafka分区状态机 1、分区状态 分区状态机用来负责集群下所有分区的状态管理,定义了 4 个状态 ,如下 : NonExistent 分区不存在或己被删除。 NewPart 2024-07-02 · kafka MQ
Kafka消息存储设计探索:高效稳定的数据存储之道 1、基本概念 主题 Topic,kafka中的消息以主题为基本单位来归类,各个主题逻辑上相互独立。 分区 Partition,每个主题又可以分为一个或多个分区,每 2024-05-18 · kafka MQ
Kafka原理与源码解析:处理Produce请求 生产者发送消息,kafka server 端在收到 Produce请求后,会由 KafkaApis 进行处理。 KafkaApis 是 server 端处理所有请 2024-04-07 · kafka MQ
kafka监控指标 1、系统指标 类型 java.lang:type=OperatingSystem 指标项 指标项说明 FreePhysicalMemorySize空闲物理 2024-02-21 · kafka
kafka配置参数整理 生产者 acks 控制着生产者发送消息后,要求 Kafka 服务器返回的确认(acknowledgment)级别。默认为1。 acks 参数可以设置为以下几个值: 2022-05-25 · kafka
Disruptor 1、背景 APM系统中的collector模块用来接收客户端上报的消息,如何提高collector的吞吐量是我们迫切关注的问题。 我们采用经典的异步消费模型来提升 2022-04-11 · 待分类
RocksDB 1、是什么 是一个使用C++编写的嵌入式 KV 存储引擎。 是Facebook基于levelDB开发的。 2、特点 高性能 RocksDB使用一套日志结构的数 2022-02-03 · 待分类