Kafka 增加消费者实例为什么超过分区数后不能继续降低积压？
Kafka 增加消费者实例为什么超过分区数后不能继续降低积压？ 本文先给出可直接复述的结论，再用最小代码说明Kafka 消费者数量 分区数 扩展上限的工作方式、判断依据、项目边界和常见误区。
核心关键词Kafka 消费者数量 分区数 扩展上限
面试知识索引 · 分类、标签与搜索
分布式系统面试题，88 道完整答案
分布式系统面试题第 2 页，显示第 51–88 题，共找到 88 道完整解析，可继续按分类、标签与关键词缩小范围。
88筛选结果
52技术分类
178检索标签
2索引分页
快速定位
清除全部筛选分类、标签与关键词搜索
技术分类52 个
全部分类5000分布式系统88AI Agent511浏览器301JavaScript285React281AI 开发262CSS240Node.js217TypeScript206Vue180前端工程化138
查看全部 52 个分类
React Native135操作系统135数据库134Docker95计算机网络94API 设计90Kubernetes90HTML89Redis89全栈开发88系统设计86HTTP85Next.js60Angular58Linux53Nuxt51PostgreSQL46可观测性46设计模式46小程序45身份与权限45无障碍44MongoDB43PWA43Web 安全43Git42前端测试42前端性能41WebAssembly40测试40AI 工程37SvelteKit37Go35前端数据管理30React Router29AI 全栈28Svelte27算法12Java10数据结构5前端手写题3
第 2 页
本页面试问题
按稳定语义路径排序
- 0051
- 0052
Kafka 死信消息重新投递前必须先确认哪些条件？
Kafka 死信消息重新投递前必须先确认哪些条件？ 本文先给出可直接复述的结论，再用最小代码说明Kafka 死信重投 redrive 幂等的工作方式、判断依据、项目边界和常见误区。
核心关键词Kafka 死信重投 redrive 幂等 - 0053
Kafka 死信 topic 中的消息必须保留哪些上下文才便于诊断？
Kafka 死信 topic 中的消息必须保留哪些上下文才便于诊断？ 本文先给出可直接复述的结论，再用最小代码说明Kafka dead letter topic 原始 topic offset 异常的工作方式、判断依据、项目边界和常见误区。
核心关键词Kafka dead letter topic 原始 topic offset 异常 - 0054
Kafka 的 exactly-once 语义覆盖从生产到消费的哪个完整链路？
Kafka 的 exactly-once 语义覆盖从生产到消费的哪个完整链路？ 本文先给出可直接复述的结论，再用最小代码说明Kafka exactly-once 语义 范围 事务的工作方式、判断依据、项目边界和常见误区。
核心关键词Kafka exactly-once 语义 范围 事务 - 0055
Kafka 如果要求主题全局有序，通常要付出什么吞吐代价？
Kafka 如果要求主题全局有序，通常要付出什么吞吐代价？ 本文先给出可直接复述的结论，再用最小代码说明Kafka 全局顺序 单分区 吞吐的工作方式、判断依据、项目边界和常见误区。
核心关键词Kafka 全局顺序 单分区 吞吐 - 0056
Kafka 消费者做幂等去重时，为什么只用 topic、partition 和 offset 可能不够？
Kafka 消费者做幂等去重时，为什么只用 topic、partition 和 offset 可能不够？ 本文先给出可直接复述的结论，再用最小代码说明Kafka 消费者幂等 去重 key offset的工作方式、判断依据、项目边界和常见误区。
核心关键词Kafka 消费者幂等 去重 key offset - 0057
Kafka 消费者组总 lag 不高但个别分区严重积压说明什么问题？
Kafka 消费者组总 lag 不高但个别分区严重积压说明什么问题？ 本文先给出可直接复述的结论，再用最小代码说明Kafka 分区 lag 热点 数据倾斜的工作方式、判断依据、项目边界和常见误区。
核心关键词Kafka 分区 lag 热点 数据倾斜 - 0058
Kafka 消费 lag 持续上升时如何区分生产突增与消费者处理瓶颈？
Kafka 消费 lag 持续上升时如何区分生产突增与消费者处理瓶颈？ 本文先给出可直接复述的结论，再用最小代码说明Kafka lag 持续上升 生产速率 消费瓶颈的工作方式、判断依据、项目边界和常见误区。
核心关键词Kafka lag 持续上升 生产速率 消费瓶颈 - 0059
Kafka compacted topic 重放时为什么不能期望看到每个历史更新？
Kafka compacted topic 重放时为什么不能期望看到每个历史更新？ 本文先给出可直接复述的结论，再用最小代码说明Kafka log compaction 重放 最新消息 key的工作方式、判断依据、项目边界和常见误区。
核心关键词Kafka log compaction 重放 最新消息 key - 0060
Kafka 消费者因处理太慢超过 max.poll.interval.ms 后会发生什么？
Kafka 消费者因处理太慢超过 max.poll.interval.ms 后会发生什么？ 本文先给出可直接复述的结论，再用最小代码说明Kafka max.poll.interval.ms 消费者离开组的工作方式、判断依据、项目边界和常见误区。
核心关键词Kafka max.poll.interval.ms 消费者离开组 - 0061
Kafka max.poll.records 设置过大为什么会同时拉长单批处理和再均衡风险？
Kafka max.poll.records 设置过大为什么会同时拉长单批处理和再均衡风险？ 本文先给出可直接复述的结论，再用最小代码说明Kafka max.poll.records max.poll.interval.ms 消费积压的工作方式、判断依据、项目边界和常见误区。
核心关键词Kafka max.poll.records max.poll.interval.ms 消费积压 - 0062
Kafka 消费者应在业务处理前还是处理后提交 offset？
Kafka 消费者应在业务处理前还是处理后提交 offset？ 本文先给出可直接复述的结论，再用最小代码说明Kafka offset commit 处理前后 投递语义的工作方式、判断依据、项目边界和常见误区。
核心关键词Kafka offset commit 处理前后 投递语义 - 0063
Kafka 如何按业务时间点找到可重放的 offset？
Kafka 如何按业务时间点找到可重放的 offset？ 本文先给出可直接复述的结论，再用最小代码说明Kafka offsetsForTimes timestamp 重放 offset的工作方式、判断依据、项目边界和常见误区。
核心关键词Kafka offsetsForTimes timestamp 重放 offset - 0064
Kafka 应用想提高吞吐又保留键级顺序时应如何并行消费？
Kafka 应用想提高吞吐又保留键级顺序时应如何并行消费？ 本文先给出可直接复述的结论，再用最小代码说明Kafka 并行消费 key 顺序的工作方式、判断依据、项目边界和常见误区。
核心关键词Kafka 并行消费 key 顺序 - 0065
业务数据库与 Kafka 之间为什么常用 outbox 表保证状态变更和事件发布不分裂？
业务数据库与 Kafka 之间为什么常用 outbox 表保证状态变更和事件发布不分裂？ 本文先给出可直接复述的结论，再用最小代码说明transactional outbox Kafka 数据库 消息 原子性的工作方式、判断依据、项目边界和常见误区。
核心关键词transactional outbox Kafka 数据库 消息 原子性 - 0066
Kafka 为什么只能依赖同一分区内的日志顺序实现键级有序？
Kafka 为什么只能依赖同一分区内的日志顺序实现键级有序？ 本文先给出可直接复述的结论，再用最小代码说明Kafka partition key 消息顺序的工作方式、判断依据、项目边界和常见误区。
核心关键词Kafka partition key 消息顺序 - 0067
Kafka 消费者能否通过 pause 和 resume 安全处理耗时业务？
Kafka 消费者能否通过 pause 和 resume 安全处理耗时业务？ 本文先给出可直接复述的结论，再用最小代码说明Kafka consumer pause resume 长耗时处理的工作方式、判断依据、项目边界和常见误区。
核心关键词Kafka consumer pause resume 长耗时处理 - 0068
Kafka 消费者遇到毒丸消息时为什么不能无限在原分区重试？
Kafka 消费者遇到毒丸消息时为什么不能无限在原分区重试？ 本文先给出可直接复述的结论，再用最小代码说明Kafka poison message 消费阻塞 死信的工作方式、判断依据、项目边界和常见误区。
核心关键词Kafka poison message 消费阻塞 死信 - 0069
Kafka 生产者 acks=0、acks=1 和 acks=all 分别牺牲什么可靠性？
Kafka 生产者 acks=0、acks=1 和 acks=all 分别牺牲什么可靠性？ 本文先给出可直接复述的结论，再用最小代码说明Kafka producer acks 0 1 all 可靠性的工作方式、判断依据、项目边界和常见误区。
核心关键词Kafka producer acks 0 1 all 可靠性 - 0070
Kafka 生产者开启重试时如何避免同一分区内的消息乱序？
Kafka 生产者开启重试时如何避免同一分区内的消息乱序？ 本文先给出可直接复述的结论，再用最小代码说明Kafka max.in.flight retries 消息乱序的工作方式、判断依据、项目边界和常见误区。
核心关键词Kafka max.in.flight retries 消息乱序 - 0071
Kafka isolation.level=read_committed 的消费者会如何处理未提交和中止事务？
Kafka isolation.level=read_committed 的消费者会如何处理未提交和中止事务？ 本文先给出可直接复述的结论，再用最小代码说明Kafka read_committed 事务消息 isolation.level的工作方式、判断依据、项目边界和常见误区。
核心关键词Kafka read_committed 事务消息 isolation.level - 0072
Kafka 修改主题分区数为什么可能破坏既有业务键的顺序预期？
Kafka 修改主题分区数为什么可能破坏既有业务键的顺序预期？ 本文先给出可直接复述的结论，再用最小代码说明Kafka 增加分区 key 顺序 hash的工作方式、判断依据、项目边界和常见误区。
核心关键词Kafka 增加分区 key 顺序 hash - 0073
Kafka 消费者发现分区没有已提交 offset 时如何决定从哪里开始读？
Kafka 消费者发现分区没有已提交 offset 时如何决定从哪里开始读？ 本文先给出可直接复述的结论，再用最小代码说明Kafka auto.offset.reset earliest latest none的工作方式、判断依据、项目边界和常见误区。
核心关键词Kafka auto.offset.reset earliest latest none - 0074
Kafka 重放前为什么要检查消息保留期与最早可用 offset？
Kafka 重放前为什么要检查消息保留期与最早可用 offset？ 本文先给出可直接复述的结论，再用最小代码说明Kafka retention offset 重放 数据不可恢复的工作方式、判断依据、项目边界和常见误区。
核心关键词Kafka retention offset 重放 数据不可恢复 - 0075
Kafka 指数退避重试为什么可能改变同分区消息的处理顺序？
Kafka 指数退避重试为什么可能改变同分区消息的处理顺序？ 本文先给出可直接复述的结论，再用最小代码说明Kafka 指数退避 重试 消息顺序的工作方式、判断依据、项目边界和常见误区。
核心关键词Kafka 指数退避 重试 消息顺序 - 0076
Kafka 消费遇到可恢复错误时应如何重试而不提交失败消息的 offset？
Kafka 消费遇到可恢复错误时应如何重试而不提交失败消息的 offset？ 本文先给出可直接复述的结论，再用最小代码说明Kafka 消费重试 offset 可恢复错误的工作方式、判断依据、项目边界和常见误区。
核心关键词Kafka 消费重试 offset 可恢复错误 - 0077
Kafka 用多个 retry topic 实现延迟重试时应按什么维度划分重试级别？
Kafka 用多个 retry topic 实现延迟重试时应按什么维度划分重试级别？ 本文先给出可直接复述的结论，再用最小代码说明Kafka retry topic 延迟重试 分级的工作方式、判断依据、项目边界和常见误区。
核心关键词Kafka retry topic 延迟重试 分级 - 0078
Kafka 消费者 seek 到指定 offset 重放数据时应先处理哪些一致性问题？
Kafka 消费者 seek 到指定 offset 重放数据时应先处理哪些一致性问题？ 本文先给出可直接复述的结论，再用最小代码说明Kafka seek offset 重放消息的工作方式、判断依据、项目边界和常见误区。
核心关键词Kafka seek offset 重放消息 - 0079
Kafka 流处理为什么要把消费 offset 与输出写入放进同一事务？
Kafka 流处理为什么要把消费 offset 与输出写入放进同一事务？ 本文先给出可直接复述的结论，再用最小代码说明Kafka sendOffsetsToTransaction exactly-once offset的工作方式、判断依据、项目边界和常见误区。
核心关键词Kafka sendOffsetsToTransaction exactly-once offset - 0080
Kafka static group membership 如何减少消费者短暂重启引发的再均衡？
Kafka static group membership 如何减少消费者短暂重启引发的再均衡？ 本文先给出可直接复述的结论，再用最小代码说明Kafka static membership group.instance.id rebalance的工作方式、判断依据、项目边界和常见误区。
核心关键词Kafka static membership group.instance.id rebalance - 0081
Kafka 压缩主题中的 tombstone 记录应如何参与异步删除语义？
Kafka 压缩主题中的 tombstone 记录应如何参与异步删除语义？ 本文先给出可直接复述的结论，再用最小代码说明Kafka tombstone log compaction 删除事件的工作方式、判断依据、项目边界和常见误区。
核心关键词Kafka tombstone log compaction 删除事件 - 0082
Kafka 事务超时后被中止时，应用侧已经产生的外部副作用能否自动回滚？
Kafka 事务超时后被中止时，应用侧已经产生的外部副作用能否自动回滚？ 本文先给出可直接复述的结论，再用最小代码说明Kafka transaction.timeout.ms 外部副作用 回滚的工作方式、判断依据、项目边界和常见误区。
核心关键词Kafka transaction.timeout.ms 外部副作用 回滚 - 0083
Kafka transactional.id 如何防止同一应用旧实例继续提交事务？
Kafka transactional.id 如何防止同一应用旧实例继续提交事务？ 本文先给出可直接复述的结论，再用最小代码说明Kafka transactional.id fencing zombie producer的工作方式、判断依据、项目边界和常见误区。
核心关键词Kafka transactional.id fencing zombie producer - 0084
Kafka 事务生产者如何保证跨多个分区的写入要么全部可见要么全部不可见？
Kafka 事务生产者如何保证跨多个分区的写入要么全部可见要么全部不可见？ 本文先给出可直接复述的结论，再用最小代码说明Kafka transaction producer 跨分区 原子提交的工作方式、判断依据、项目边界和常见误区。
核心关键词Kafka transaction producer 跨分区 原子提交 - 0085
PostgreSQL LISTEN/NOTIFY 的异步通知在事务和连接断线下有什么投递边界？
PostgreSQL LISTEN/NOTIFY 的异步通知在事务和连接断线下有什么投递边界？ 本文先给出可直接复述的结论，再用最小代码说明PostgreSQL LISTEN NOTIFY 事务 通知 投递语义的工作方式、判断依据、项目边界和常见误区。
核心关键词PostgreSQL LISTEN NOTIFY 事务 通知 投递语义 - 0086
PostgreSQL 订阅者落后时，发布端为什么可能保留大量 WAL 并造成存储积压？
PostgreSQL 订阅者落后时，发布端为什么可能保留大量 WAL 并造成存储积压？ 本文先给出可直接复述的结论，再用最小代码说明PostgreSQL 逻辑复制 slot WAL 积压的工作方式、判断依据、项目边界和常见误区。
核心关键词PostgreSQL 逻辑复制 slot WAL 积压 - 0087
PostgreSQL 逻辑复制如何用复制位点避免订阅者重复应用变更？
PostgreSQL 逻辑复制如何用复制位点避免订阅者重复应用变更？ 本文先给出可直接复述的结论，再用最小代码说明PostgreSQL logical replication LSN 消费位点的工作方式、判断依据、项目边界和常见误区。
核心关键词PostgreSQL logical replication LSN 消费位点 - 0088
PostgreSQL 逻辑复制能保证哪些事务提交顺序，不能把它误认成什么消息顺序？
PostgreSQL 逻辑复制能保证哪些事务提交顺序，不能把它误认成什么消息顺序？ 本文先给出可直接复述的结论，再用最小代码说明PostgreSQL logical replication 事务提交顺序的工作方式、判断依据、项目边界和常见误区。
核心关键词PostgreSQL logical replication 事务提交顺序