频繁的 Rebalance 会导致消费停顿与重复消费。引入静态成员(Static Membership)并合理设置 session.timeout.ms 与 max.poll.interval.ms 可显著抑制风暴。 !Kafka 架构 一、静态成员与超时配置
分类:消息队列与存储
共 2 篇文章消息队列与存储相关技术文章
专注于分布式系统、Linux内核、数据库存储与后端工程实践
消息队列与存储相关技术文章
频繁的 Rebalance 会导致消费停顿与重复消费。引入静态成员(Static Membership)并合理设置 session.timeout.ms 与 max.poll.interval.ms 可显著抑制风暴。 !Kafka 架构 一、静态成员与超时配置
Apache Kafka 之所以拥有单机十万级吞吐量,核心在于利用了 Linux 内核的 零拷贝(ZeroCopy) 技术。索引文件使用 mmap 映射内存,而消息日志的消费直接调用 sendfile 系统调用完成 DMA 传输,避免了上下文切换与内核到用户态的内存复制。 一、Java 中的 FileChannel.t