Timer 接口 SystemTimer 类 delayQueue 字段。它保存了该定时器下管理的所有 Bucke...[作者空间]
TimerTask 类 TimerTaskEntry 类 TimerTaskList 类 taskCounter，...[作者空间]
一、调优吞吐量 broker参数 增加num.replica.fetchers，不要超过CPU核数 调优gc,避免...[作者空间]
消息系统的用户从更严格的幂等生产者语义中获益良多，即每个消息写将被精确地持久化一次，没有重复和数据丢失——即使在客...[作者空间]
如果启动出现如下报错, Kafka broker端配置的“transaction.max.timeout”默认为1...[作者空间]
查看当前消费组信息 使用重置脚本的前提是,消费组是非激活状态.有2个执行选项:--dry-run 生成计划--e...[作者空间]
以下是针对kafka 1.1.1版本编译流程及在idea中启动的步骤 从 GitHub 网站，git clone ...[作者空间]
添加Acl 创建用户用于测试Acl授权 添加acl 要添加一个acl “允许用户Bob和Alice从IP 198....[作者空间]
kafka在设计上大量使用了Selector+Channel+Buffer的设计原理.所以在开始之前简单介绍一下N...[作者空间]
以Kafka 2.3.0版本为例,实现通过配置SASL SCRAM + ACL来实现动态增减用户.以下是具体步骤 ...[作者空间]
