Kafka 消费者组总 lag 不高但个别分区严重积压说明什么问题?
Kafka 消费者组总 lag 不高但个别分区严重积压说明什么问题? 本文先给出可直接复述的结论,再用最小代码说明Kafka 分区 lag 热点 数据倾斜的工作方式、判断依据、项目边界和常见误区。
程序员面试题库第 30 页,收录第 1451–1500 题,共 5000 道完整解析,覆盖前端、JavaScript、React、Vue、Node.js、AI Agent、网络、数据库与系统设计。
按稳定语义路径排序
Kafka 消费者组总 lag 不高但个别分区严重积压说明什么问题? 本文先给出可直接复述的结论,再用最小代码说明Kafka 分区 lag 热点 数据倾斜的工作方式、判断依据、项目边界和常见误区。
Kafka 消费 lag 持续上升时如何区分生产突增与消费者处理瓶颈? 本文先给出可直接复述的结论,再用最小代码说明Kafka lag 持续上升 生产速率 消费瓶颈的工作方式、判断依据、项目边界和常见误区。
Kafka compacted topic 重放时为什么不能期望看到每个历史更新? 本文先给出可直接复述的结论,再用最小代码说明Kafka log compaction 重放 最新消息 key的工作方式、判断依据、项目边界和常见误区。
Kafka 消费者因处理太慢超过 max.poll.interval.ms 后会发生什么? 本文先给出可直接复述的结论,再用最小代码说明Kafka max.poll.interval.ms 消费者离开组的工作方式、判断依据、项目边界和常见误区。
Kafka max.poll.records 设置过大为什么会同时拉长单批处理和再均衡风险? 本文先给出可直接复述的结论,再用最小代码说明Kafka max.poll.records max.poll.interval.ms 消费积压的工作方式、判断依据、项目边界和常见误区。
Kafka 消费者应在业务处理前还是处理后提交 offset? 本文先给出可直接复述的结论,再用最小代码说明Kafka offset commit 处理前后 投递语义的工作方式、判断依据、项目边界和常见误区。
Kafka 如何按业务时间点找到可重放的 offset? 本文先给出可直接复述的结论,再用最小代码说明Kafka offsetsForTimes timestamp 重放 offset的工作方式、判断依据、项目边界和常见误区。
Kafka 应用想提高吞吐又保留键级顺序时应如何并行消费? 本文先给出可直接复述的结论,再用最小代码说明Kafka 并行消费 key 顺序的工作方式、判断依据、项目边界和常见误区。
业务数据库与 Kafka 之间为什么常用 outbox 表保证状态变更和事件发布不分裂? 本文先给出可直接复述的结论,再用最小代码说明transactional outbox Kafka 数据库 消息 原子性的工作方式、判断依据、项目边界和常见误区。
Kafka 为什么只能依赖同一分区内的日志顺序实现键级有序? 本文先给出可直接复述的结论,再用最小代码说明Kafka partition key 消息顺序的工作方式、判断依据、项目边界和常见误区。
Kafka 消费者能否通过 pause 和 resume 安全处理耗时业务? 本文先给出可直接复述的结论,再用最小代码说明Kafka consumer pause resume 长耗时处理的工作方式、判断依据、项目边界和常见误区。
Kafka 消费者遇到毒丸消息时为什么不能无限在原分区重试? 本文先给出可直接复述的结论,再用最小代码说明Kafka poison message 消费阻塞 死信的工作方式、判断依据、项目边界和常见误区。
Kafka 生产者 acks=0、acks=1 和 acks=all 分别牺牲什么可靠性? 本文先给出可直接复述的结论,再用最小代码说明Kafka producer acks 0 1 all 可靠性的工作方式、判断依据、项目边界和常见误区。
Kafka 生产者开启重试时如何避免同一分区内的消息乱序? 本文先给出可直接复述的结论,再用最小代码说明Kafka max.in.flight retries 消息乱序的工作方式、判断依据、项目边界和常见误区。
Kafka isolation.level=read_committed 的消费者会如何处理未提交和中止事务? 本文先给出可直接复述的结论,再用最小代码说明Kafka read_committed 事务消息 isolation.level的工作方式、判断依据、项目边界和常见误区。
Kafka 修改主题分区数为什么可能破坏既有业务键的顺序预期? 本文先给出可直接复述的结论,再用最小代码说明Kafka 增加分区 key 顺序 hash的工作方式、判断依据、项目边界和常见误区。
Kafka 消费者发现分区没有已提交 offset 时如何决定从哪里开始读? 本文先给出可直接复述的结论,再用最小代码说明Kafka auto.offset.reset earliest latest none的工作方式、判断依据、项目边界和常见误区。
Kafka 重放前为什么要检查消息保留期与最早可用 offset? 本文先给出可直接复述的结论,再用最小代码说明Kafka retention offset 重放 数据不可恢复的工作方式、判断依据、项目边界和常见误区。
Kafka 指数退避重试为什么可能改变同分区消息的处理顺序? 本文先给出可直接复述的结论,再用最小代码说明Kafka 指数退避 重试 消息顺序的工作方式、判断依据、项目边界和常见误区。
Kafka 消费遇到可恢复错误时应如何重试而不提交失败消息的 offset? 本文先给出可直接复述的结论,再用最小代码说明Kafka 消费重试 offset 可恢复错误的工作方式、判断依据、项目边界和常见误区。
Kafka 用多个 retry topic 实现延迟重试时应按什么维度划分重试级别? 本文先给出可直接复述的结论,再用最小代码说明Kafka retry topic 延迟重试 分级的工作方式、判断依据、项目边界和常见误区。
Kafka 消费者 seek 到指定 offset 重放数据时应先处理哪些一致性问题? 本文先给出可直接复述的结论,再用最小代码说明Kafka seek offset 重放消息的工作方式、判断依据、项目边界和常见误区。
Kafka 流处理为什么要把消费 offset 与输出写入放进同一事务? 本文先给出可直接复述的结论,再用最小代码说明Kafka sendOffsetsToTransaction exactly-once offset的工作方式、判断依据、项目边界和常见误区。
Kafka static group membership 如何减少消费者短暂重启引发的再均衡? 本文先给出可直接复述的结论,再用最小代码说明Kafka static membership group.instance.id rebalance的工作方式、判断依据、项目边界和常见误区。
Kafka 压缩主题中的 tombstone 记录应如何参与异步删除语义? 本文先给出可直接复述的结论,再用最小代码说明Kafka tombstone log compaction 删除事件的工作方式、判断依据、项目边界和常见误区。
Kafka 事务超时后被中止时,应用侧已经产生的外部副作用能否自动回滚? 本文先给出可直接复述的结论,再用最小代码说明Kafka transaction.timeout.ms 外部副作用 回滚的工作方式、判断依据、项目边界和常见误区。
Kafka transactional.id 如何防止同一应用旧实例继续提交事务? 本文先给出可直接复述的结论,再用最小代码说明Kafka transactional.id fencing zombie producer的工作方式、判断依据、项目边界和常见误区。
Kafka 事务生产者如何保证跨多个分区的写入要么全部可见要么全部不可见? 本文先给出可直接复述的结论,再用最小代码说明Kafka transaction producer 跨分区 原子提交的工作方式、判断依据、项目边界和常见误区。
PostgreSQL LISTEN/NOTIFY 的异步通知在事务和连接断线下有什么投递边界? 本文先给出可直接复述的结论,再用最小代码说明PostgreSQL LISTEN NOTIFY 事务 通知 投递语义的工作方式、判断依据、项目边界和常见误区。
PostgreSQL 订阅者落后时,发布端为什么可能保留大量 WAL 并造成存储积压? 本文先给出可直接复述的结论,再用最小代码说明PostgreSQL 逻辑复制 slot WAL 积压的工作方式、判断依据、项目边界和常见误区。
PostgreSQL 逻辑复制如何用复制位点避免订阅者重复应用变更? 本文先给出可直接复述的结论,再用最小代码说明PostgreSQL logical replication LSN 消费位点的工作方式、判断依据、项目边界和常见误区。
PostgreSQL 逻辑复制能保证哪些事务提交顺序,不能把它误认成什么消息顺序? 本文先给出可直接复述的结论,再用最小代码说明PostgreSQL logical replication 事务提交顺序的工作方式、判断依据、项目边界和常见误区。
Dockerfile 中 ADD 和 COPY 的区别是什么,为什么官方推荐优先用 COPY? 本文先给出可直接复述的结论,再用最小代码说明Dockerfile ADD COPY 区别的工作方式、判断依据、项目边界和常见误区。
为什么基于 Alpine 的镜像在 DNS 解析或本地化上可能出现与 glibc 镜像不同的行为? 本文先给出可直接复述的结论,再用最小代码说明Alpine musl glibc 差异 Docker的工作方式、判断依据、项目边界和常见误区。
Docker 构建参数 ARG 与环境变量 ENV 在何时可见、如何影响镜像? 本文先给出可直接复述的结论,再用最小代码说明Docker ARG ENV 区别的工作方式、判断依据、项目边界和常见误区。
docker buildx bake 如何用一份声明式文件编排多个相关镜像的构建? 本文先给出可直接复述的结论,再用最小代码说明docker buildx bake 多目标 构建的工作方式、判断依据、项目边界和常见误区。
Dockerfile 中 ARG 的作用域规则是什么,为什么 FROM 之前的 ARG 要重新声明? 本文先给出可直接复述的结论,再用最小代码说明Dockerfile ARG 作用域 FROM 之前的工作方式、判断依据、项目边界和常见误区。
本文解释 Docker 构建缓存按层匹配的具体逻辑:缓存键组成、复用条件与失效传播链,并以依赖清单与源码分离的 COPY 顺序为例说明实践,同时指出忽略 .dockerignore 或合并 COPY 带来的缓存失效扩大及代价。
Docker 构建上下文是什么,为什么上下文过大会让构建变慢? 本文先给出可直接复述的结论,再用最小代码说明Docker 构建上下文 build context的工作方式、判断依据、项目边界和常见误区。
BuildKit 如何自动并行执行互不依赖的 Dockerfile 构建步骤? 本文先给出可直接复述的结论,再用最小代码说明BuildKit 并行构建 依赖图的工作方式、判断依据、项目边界和常见误区。
docker buildx create 创建远程或容器化 builder 实例解决什么问题? 本文先给出可直接复述的结论,再用最小代码说明docker buildx create builder 驱动的工作方式、判断依据、项目边界和常见误区。
Docker 构建的 registry、local、gha 等缓存后端各有什么取舍? 本文先给出可直接复述的结论,再用最小代码说明Docker 构建缓存后端 registry local gha的工作方式、判断依据、项目边界和常见误区。
为什么 Dockerfile 里应先 COPY 依赖清单再 COPY 源码才能利用好构建缓存? 本文先给出可直接复述的结论,再用最小代码说明Dockerfile COPY 顺序 缓存 依赖的工作方式、判断依据、项目边界和常见误区。
BuildKit 的 RUN --mount=type=cache 如何解决包管理器缓存反复下载的问题? 本文先给出可直接复述的结论,再用最小代码说明BuildKit cache mount 构建缓存 apt npm的工作方式、判断依据、项目边界和常见误区。
如何用 --cache-to 和 --cache-from 在 CI 之间共享 Docker 构建缓存? 本文先给出可直接复述的结论,再用最小代码说明Docker registry cache cache-to cache-from的工作方式、判断依据、项目边界和常见误区。
Dockerfile 的 COPY --from 能否引用外部镜像,它和引用构建阶段有什么区别? 本文先给出可直接复述的结论,再用最小代码说明COPY --from 镜像 构建阶段 区别的工作方式、判断依据、项目边界和常见误区。
Docker 中的 dangling(<none>)镜像如何产生,如何安全清理? 本文先给出可直接复述的结论,再用最小代码说明Docker dangling 镜像 <none> 清理的工作方式、判断依据、项目边界和常见误区。
Docker 构建中途失败时,如何利用中间层镜像进入现场排查问题? 本文先给出可直接复述的结论,再用最小代码说明Docker 构建失败 调试 中间层的工作方式、判断依据、项目边界和常见误区。
如何分析一个已有镜像每层的大小与内容,定位体积浪费在哪一层? 本文先给出可直接复述的结论,再用最小代码说明Docker 镜像分层体积分析 docker history 与 dive的工作方式、判断依据、项目边界和常见误区。
Dockerfile 中哪些指令会产生新的镜像层,这对构建设计意味着什么? 本文先给出可直接复述的结论,再用最小代码说明Dockerfile 指令 镜像层 RUN COPY的工作方式、判断依据、项目边界和常见误区。