💬 讨论 (10)
11 条回复 · 5 位参与者
讨论围绕 KIP-1356 展开,旨在为支持 Headers 的状态存储引入 IQv2 接口。参与者主要就 Session Store 的支持范围、查询类型的命名规范(如统一添加 Timestamped 前缀)以及对现有查询类型的兼容性进行了深入探讨并达成共识。讨论最后提出了关于是否采用 Record 模型统一 API 设计的高层建议。
@Alieh Saeedi: 建议遵循命名约定(如使用 key() 而非 getKey())并修正示例中的类型错误(long 改为 Long)。
@Matthias J. Sax: 指出应明确 Session Store 的支持情况,建议扩展现有查询类型的支持范围,并提议统一命名风格;最后提出是否可用 Record 模型替代 ValueTimestampHeaders 以实现长期 API 统一。
@Jess Jin: 确认将包含 Session Store 支持,采纳了关于命名(如 SessionKeyWithHeadersQuery)和现有查询类型兼容性的建议,并更新了 Wiki 页面。
已就 Session Store 支持、命名规范及现有查询类型兼容性达成共识并更新文档;Matthias 提出的关于采用 Record 模型的新建议尚待进一步讨论。
8 条回复 · 4 位参与者
讨论围绕 KIP-1327 如何定义“新分区”以及配置设计展开。Jun Rao 提出原设计基于分区创建时间的配置不够直观,建议改用“消费者组创建时间”来区分新旧分区,并引入新配置 `auto.offset.reset.new.partitions`。该方案最终获得社区认可,作者已据此更新了提案。
@Jun Rao: 认为原配置 `auto.offset.reset.max.age.ms` 难以理解,建议移除它,改为基于组创建时间区分新旧分区,并新增 `auto.offset.reset.new.partitions` 配置以允许对新分区设置独立的重置策略。
@黃竣陽: 最初解释了使用分区年龄而非组创建时间的原因(避免消费者长时间空闲后出现数据消费不一致),但在 Jun Rao 提出更优方案后,同意并更新了 KIP。
@Chia-Ping Tsai: 赞同 Jun Rao 的提议,认为该方案能解决绝大多数投诉,同时建议在 KIP 中补充协议变更的表格说明及针对现有消费者组的升级指引。
社区达成共识,放弃原提议的 `auto.offset.reset.max.age.ms`,转而采用基于组创建时间的分类逻辑,并引入新配置 `auto.offset.reset.new.partitions`。作者已更新 KIP 文档,后续将完善协议变更细节及升级场景说明。
4 条回复 · 2 位参与者
讨论主要围绕 KIP-1332 中缓冲区内存分配策略的命名及记录大小估算公式展开。Jun Rao 提出了优化命名建议并指出了计算公式的差异,Lianet 澄清了“hasRoom”检查与块数量估算逻辑的区别并据此更新了 KIP。最终 Jun Rao 对更新后的提案表示认可。
@Jun Rao: 建议将分配策略名称从“static/dynamic”改为“full/incremental”,并指出当前代码中 hasRoomFor 的计算公式与 KIP 描述存在差异。
@Lianet Magrans: 同意更改策略名称;澄清“hasRoom”检查沿用悲观策略(使用未压缩大小)以避免拒绝,而块数量估算采用乐观策略(使用压缩大小)。
Jun Rao 最终确认 KIP 内容无误,讨论达成一致,KIP 准备就绪。
3 条回复 · 4 位参与者
讨论主要围绕 Kafka 4.4.0 版本的发布时间表展开,发布经理提出了两个方案供社区投票。最终决定采用方案 1(推迟数周发布),KIP 冻结日期定为 7 月 8 日,并相应调整了后续里程碑节点。
@Omnia Ibrahim: 提出了两种发布时间表选项,最终确认采用方案 1 并锁定了 KIP 冻结日期为 7 月 8 日。
@Chia-Ping Tsai: 支持方案 1,认为该方案有助于平滑过渡到每年 3 次发布的理想节奏,并修正了 4.5.0 代码冻结日期的计算。
@Uladzislau Blok: 通知已将已通过的 KIP-1321 添加到 4.4.0 的发布范围内。
已确定 4.4.0 版本将按方案 1 执行;下一步将在其他讨论帖中确定整体发布节奏,并继续跟进新纳入的 KIP。
3 条回复 · 2 位参与者
讨论主要关于将 Kafka 网站 4.2 和 4.3 版本的 `generated` 文件夹从 `static/` 目录迁移至 `content/` 目录。经过 mimaison 的纠正和 muralibasani 的实施,最终确定了迁移方案并更新了相关代码逻辑以保持向后兼容性。
@mimaison: 指出 `generated` 文件夹应从构建产物所在的 `content/en` 路径获取,建议删除 `static` 下的副本并将 4.3 的文件夹移至正确位置。
@muralibasani: 执行了迁移操作,将文件移至 `content/en` 下,并更新了短代码逻辑以支持新路径同时兼容旧版本 (07-41)。
已达成一致并完成实施,将 `generated` 文件夹移至 `content/en` 目录,并确保了旧版本文档的正常访问。
3 条回复 · 3 位参与者
本讨论围绕 KIP-1357 展开,旨在为 Streams 组引入代理端自定义分配器支持,以弥补 KIP-1071 的功能缺失。作者根据反馈同意调整配置命名以与 KIP-848 保持一致,并重构接口设计以提升灵活性和演进性。讨论还涉及配置验证的范围界定及自定义分配器访问代理配置的能力。
@David Jacot: 建议配置项命名应与 KIP-848 保持一致,并改进接口设计(使用接口代替 POJO/Records)以提高灵活性。
@Gabriella Fu: 接受了关于配置命名和接口重构的建议,但认为扩展动态组配置验证范围超出了本 KIP 的范畴。
@Lucas Brutschy: 支持配置命名的修改意见,并询问自定义 TaskAssignor 是否能像消费者分配器一样获取代理配置。
作者将更新 KIP 以采纳关于配置命名和接口设计的建议,同时维持原有的配置验证范围;关于自定义分配器获取代理配置的问题尚待确认。
3 条回复 · 2 位参与者
讨论围绕 KIP-1238 展开,旨在为 Kafka Streams 的 TopologyTestDriver 引入多分区支持。双方重点讨论了 API 设计(构建器模式与构造函数)、模式检测逻辑以及主题声明规则,Sébastien 根据 Matthias 的反馈完善了提案细节。
@Sébastien Viale: 提议采用构建器作为单一入口点并隐式检测模式;确认多分区模式下输入主题必须声明,否则抛出异常,输出主题可自动创建。
@Matthias J. Sax: 建议明确区分入口点(构造函数对应单分区,Builder 对应多分区)以降低用户理解成本;建议增强类型安全并明确主题声明规则。
讨论已达成一致,Matthias 对更新后的提案表示认可,下一步将推进该 KIP 的实现。
3 条回复 · 2 位参与者
讨论主要围绕 KIP-1313 中请求头版本映射机制的设计展开。Jun Rao 指出原有方案缺乏通用性,建议采用通用的 headerVersions 映射并支持开放式版本范围以适应未来扩展。Andrew Schofield 采纳了这些建议更新了 KIP,并重新引入了 client ID 优化。
@Jun Rao: 反对添加仅适用于请求的特定字段,建议引入通用的 headerVersion 映射机制,以便将请求/响应版本映射到头部版本。
@Jun Rao: 建议版本映射的键应支持开放式范围(如 '3+'),避免未来请求版本变更时频繁修改映射配置。
@Andrew Schofield: 同意 Jun 的建议,已将方案修改为在请求和响应模式中使用 headerVersions 映射,并支持开放式版本范围。
双方就版本映射方案达成一致,KIP 已更新为使用通用的 headerVersions 映射机制并支持开放式版本范围,同时重新引入了 client ID 优化。
2 条回复 · 1 位参与者
Dependabot 发起了一个 PR,旨在将 kafka-site 项目的 hugo-extended 依赖从 0.161.1 升级到 0.163.1。随后该 PR 被标记为已被新的 PR #881 取代,并最终被关闭。
@dependabot[bot]: 建议将 hugo-extended 依赖版本从 0.161.1 升级至 0.163.1。
@dependabot[bot]: 指出该 PR 已被 PR #881 取代。
PR #878 已关闭,依赖更新工作将转移到 PR #881 进行。
2 条回复 · 2 位参与者
本次讨论主要关于修复 kafka-site 仓库中的一个配置名称拼写错误。提交者 morgando 指出配置项名称应从 `listener.security.property.map` 更正为 `listener.security.protocol.map`。该 PR 随后被维护者审核并合并。
@morgando: 发现配置名称拼写错误,建议将 `listener.security.property.map` 修改为 `listener.security.protocol.map`。
@showuon: 认可该修复,称赞发现该错误,并合并了代码。
PR #882 已被合并,配置名称拼写错误已修复。