企业官网建设流程全解析

做网站设计的都转行干啥了,应用软件是什么,上海专业做网站的公司,wordpress图片特效插件目录标题Apache Kafka 3.2.3 与 3.9.1 版本差异详细对比一、版本概述1.1 基本信息1.2 发布时间线二、架构层面的重大变化2.1 KRaft 模式演进 (最重大变化)2.2 ZooKeeper 淘汰计划三、核心功能新增与改进3.1 分层存储 (Tiered Storage)3.2 消费者再平衡协议3.3 镜像复制增强 (Mi…目录标题Apache Kafka 3.2.3 与 3.9.1 版本差异详细对比一、版本概述1.1 基本信息1.2 发布时间线二、架构层面的重大变化2.1 KRaft 模式演进 (最重大变化)2.2 ZooKeeper 淘汰计划三、核心功能新增与改进3.1 分层存储 (Tiered Storage)3.2 消费者再平衡协议3.3 镜像复制增强 (MirrorMaker 2.0)3.4 压缩支持增强3.5 机架感知分配四、Kafka Streams 重大改进4.1 状态存储增强4.2 异常处理改进4.3 交互式查询 v2 (IQv2) 增强4.4 其他 Streams 改进五、Kafka Connect 增强功能5.1 REST API 改进5.2 转换增强5.3 运维改进六、监控与可观测性6.1 客户端指标6.2 JMX 指标增强6.3 分层存储指标七、安全与认证改进7.1 SCRAM 支持7.2 证书管理7.3 ACL 改进7.4 安全修复八、配置与部署改进8.1 Docker 支持8.2 配置提供者8.3 其他配置改进九、性能与可靠性改进9.1 性能优化9.2 可靠性增强9.3 Bug 修复十、API 变更与兼容性10.1 废弃的 API10.2 新增 API10.3 恢复的 API十一、Java 版本支持变化十二、升级路径建议12.1 从 3.2.3 升级到 3.9.1 的推荐路径12.2 升级前检查清单12.3 关键配置变更十三、重要 KIP 索引13.1 架构相关13.2 分层存储13.3 Kafka Streams13.4 Kafka Connect十四、迁移注意事项14.1 ZooKeeper 到 KRaft 迁移14.2 Java 版本迁移14.3 分层存储迁移十五、已知问题与限制15.1 3.2.3 已知问题15.2 3.9.1 已知限制15.3 升级兼容性十六、总结与建议16.1 主要变化总结16.2 升级建议16.3 未来规划十七、参考资源官方文档官方博客KIP 文档其他资源Apache Kafka 3.2.3 与 3.9.1 版本差异详细对比文档生成时间: 2026-01-15调研范围: Apache Kafka 3.2.3 至 3.9.1 所有中间版本数据来源: Apache Kafka 官方发布说明、Confluent 博客、官方文档一、版本概述1.1 基本信息特性Kafka 3.2.3Kafka 3.9.1发布日期2022年8月2025年5月版本类型Bug修复版本Bug修复版本基础版本Kafka 3.2.x 系列Kafka 3.9.x 系列ZooKeeper 状态必需依赖已废弃(将在4.0移除)KRaft 状态早期访问阶段生产就绪Java 支持Java 8/11Java 17/23 (Java 11 已废弃)主要安全修复CVE-2022-34917多项安全增强1.2 发布时间线3.2.3 (2022-08) → 3.3.0 → 3.4.0 → 3.5.0 → 3.6.0 → 3.7.0 → 3.8.0 → 3.9.0 → 3.9.1 (2025-05)二、架构层面的重大变化2.1 KRaft 模式演进 (最重大变化)特性Kafka 3.2.3Kafka 3.9.1KRaft 状态早期访问 (Early Access)生产就绪(Production Ready)ZooKeeper 依赖必需完全可选已标记为废弃动态控制器仲裁不支持支持(KIP-853)JBOD 支持不支持支持 (生产就绪)ZK 迁移工具基础支持完整支持(最终版本)关键里程碑版本:3.3.0: KRaft 模式标记为生产就绪 (KIP-833)3.4.0: 引入 ZK 到 KRaft 迁移工具 (KIP-866)3.5.0: ZooKeeper 正式标记为废弃3.7.0: JBOD 在 KRaft 中进入早期访问3.8.0: JBOD 在 KRaft 中生产就绪3.9.0: 动态 KRaft 仲裁成员管理 (KIP-853)2.2 ZooKeeper 淘汰计划3.5.0 开始: ZooKeeper 正式标记为废弃3.9.0: 最后一个支持 ZooKeeper 的主要版本4.0.0: ZooKeeper 将被完全移除迁移路径建议:# 从旧版本升级到 4.0 的示例路径Kafka1.0→3.4→ ZooKeeper3.8→3.9→ 执行ZK迁移 →4.0三、核心功能新增与改进3.1 分层存储 (Tiered Storage)版本功能状态3.2.3不支持3.6.0早期访问引入 (KIP-405)3.7.0新增监控指标 (KIP-963)3.8.0支持 JBOD 配置3.9.0生产就绪3.9.0 新增功能:KIP-950: 按主题动态禁用分层存储KIP-956: 分层存储配额管理KIP-1005: 暴露 EarliestLocalOffset 和 TieredOffsetKIP-1057: kafka-dump-log.sh 支持检查分层存储记录3.2 消费者再平衡协议版本功能3.2.3传统再平衡协议3.7.0KIP-848 下一代协议 (早期访问)3.8.0KIP-848 预览版多项 bug 修复3.9.1持续改进中KIP-848 优势:将复杂性从消费者端移至 Group Coordinator完全重构为增量式协议不再依赖全局同步屏障更高效、更快速3.3 镜像复制增强 (MirrorMaker 2.0)版本新增功能3.4.0KIP-787: MM2 管理资源的自定义 Admin 实现3.5.0KIP-710: 分布式模式完全支持KIP-875: 原生 Offset 管理支持KIP-894: 使用 IncrementalAlterConfig 同步配置KAFKA-14021: 支持 Exactly-Once 语义3.9.0KIP-1031: MirrorSourceConnector 中控制 offset 转换3.4 压缩支持增强版本功能3.2.3仅支持默认压缩级别3.8.0KIP-390: 支持自定义压缩级别配置3.5 机架感知分配版本功能3.4.0引入协议变更 (KIP-881)3.5.0内置分配器完全支持机架感知3.7.0KIP-925: Kafka Streams 支持机架感知任务分配四、Kafka Streams 重大改进4.1 状态存储增强功能引入版本描述版本化状态存储3.5.0 (KIP-889)提高乱序记录连接的准确性可共享状态存储3.8.0 (KIP-813)跨应用共享状态存储数据自定义任务分配3.8.0 (KIP-924)可插拔的自定义任务分配器4.2 异常处理改进版本功能3.5.0KIP-399: ProductionExceptionHandler 扩展支持序列化异常3.9.0KIP-1033: 处理过程中发生的异常处理器3.9.0KIP-1049: 新增 log.summary.interval.ms 配置4.3 交互式查询 v2 (IQv2) 增强版本功能3.7.0KIP-960/968: 版本化状态存储的 IQ 支持KIP-985: reverseRange 和 reverseAll 查询KIP-992: TimestampedKeyQuery 和 TimestampedRangeQuery4.4 其他 Streams 改进版本功能3.5.0KIP-907: Boolean Serde 支持3.7.0KIP-954: 自定义存储类型的默认 DSL 配置3.7.0KIP-962: 放宽非空键要求3.7.0KIP-988: Streams Standby 更新监听器3.8.0KIP-989: 改进 StateStore Iterator 指标五、Kafka Connect 增强功能5.1 REST API 改进版本功能3.5.0KIP-875: Offset 管理的 REST API 端点3.8.0KIP-477: PATCH 方法支持部分配置更新3.9.0KIP-1017: 健康检查端点3.9.0KIP-970: 废弃冗余任务配置端点5.2 转换增强版本功能3.9.0KIP-1040: InsertField、ExtractField 等转换中改进可空值处理5.3 运维改进版本功能3.7.0KIP-976: 集群范围的动态日志调整3.7.0KIP-980: 允许以停止状态创建连接器3.7.0KIP-959: BooleanConverter 支持3.8.0KIP-1004: 强制执行 tasks.max 属性六、监控与可观测性6.1 客户端指标版本功能3.7.0KIP-714: 客户端指标和可观测性3.7.0KIP-1000: 客户端指标配置资源管理6.2 JMX 指标增强版本功能3.7.0KIP-938: 新增 11 个 KRaft 性能指标3.7.0KIP-1001: 新增 CurrentControllerId 指标3.8.0KIP-1019: 暴露 isMeasurable() 方法3.8.0KIP-1036: 扩展 RecordDeserializationException6.3 分层存储指标版本功能3.7.0KIP-963: 分层存储额外指标七、安全与认证改进7.1 SCRAM 支持版本功能3.5.0KIP-900: KRaft 中支持 Broker 间 SCRAM 认证7.2 证书管理版本功能3.7.0KIP-978: 允许动态重载不同 DN/SAN 的证书7.3 ACL 改进版本功能3.9.1KAFKA-18051: 禁止创建不包含冒号的 principal 的 ACL7.4 安全修复3.2.3 主要修复:CVE-2022-34917 及其他 7 个安全问题3.9.1 修复的安全问题:KAFKA-17792: Header 解析超时和大量内存使用问题KAFKA-18281: 非广播监听器的路由验证八、配置与部署改进8.1 Docker 支持版本功能3.7.0KIP-975: 官方 Apache Kafka Docker 镜像3.8.0KIP-974: 基于 GraalVM 的 Native Docker 镜像3.8.0KIP-1028: 官方 Docker 镜像8.2 配置提供者版本功能3.5.0KIP-887: EnvVarConfigProvider 从环境变量获取配置3.8.0KIP-993: 限制文件和目录 ConfigProvider 访问的文件8.3 其他配置改进版本功能3.3.0KIP-848: 新一代消费者再平衡协议3.4.0KIP-854: 更高效地清理 Producer ID3.5.0KIP-903: 具有 stale broker epoch 的副本不能加入 ISR3.7.0KIP-890: 事务服务端防御3.8.0KIP-899: 允许生产者和消费者重新引导3.8.0KIP-1018: 引入 max remote fetch timeout 配置3.8.0KIP-1037: WriteTxnMarkers API 支持 Alter Cluster 权限3.8.0KIP-1041: 废弃 offsets.commit.required.acks 配置九、性能与可靠性改进9.1 性能优化版本功能3.3.0改进的分区可扩展性3.4.0Producer ID 清理优化 (KIP-854)3.7.0KIP-951: 客户端 Leader 发现优化3.7.0KIP-580: 客户端指数退避重试9.2 可靠性增强版本功能3.5.0KIP-903: 防止数据副本的 ISR 加入问题3.7.0KIP-858: KRaft 中 JBOD 磁盘故障处理3.8.0KIP-848: 下一代再平衡协议 (预览)3.9.1KAFKA-18326: 缓存存储可能返回已删除值的修复9.3 Bug 修复3.9.1 重要修复:KAFKA-12679: 重平衡时目录活锁问题KAFKA-15931: 分层存储读取中断时缓存事务索引关闭KAFKA-16407/16434: ForeignKey INNER JOIN 问题KAFKA-17299: Kafka Streams 消费者停止消费KAFKA-17455: 客户端限流后的 TaskCorruptedExceptionKAFKA-17635: exactly_once_v2 事件丢失KAFKA-18063: SnapshotRegistry 内存泄漏KAFKA-18171: bootstrap.servers 行为变更KAFKA-18263: 静态成员重新加入时的锁问题KAFKA-18723: KRaft 处理损坏记录KAFKA-18758: 关闭时的 NullPointerExceptionKAFKA-18943: Kafka Streams 在任务撤销期间错误提交事务十、API 变更与兼容性10.1 废弃的 APIAPI 版本废弃版本移除版本说明Kafka 2.1 之前的客户端 API3.7.04.0.0KIP-896Log4J Appender3.8.04.0.0KIP-719offsets.commit.required.acks3.8.04.0.0KIP-1041Java 11 (Broker/Tools)3.7.04.0.0KIP-1013kafka.serializer.Decoder3.8.0未来KIP-104710.2 新增 API版本新增 API3.5.0EnvVarConfigProvider3.7.0客户端指标管理 API3.8.0PATCH 方法支持 (Connect REST)3.9.0动态 KRaft 仲裁管理 API3.9.0健康检查端点10.3 恢复的 API版本功能3.9.1Produce v4-v6 取消废弃标记3.9.1Metadata v0-v3 取消废弃标记3.9.1DeleteGroups v0 取消废弃标记3.9.1SaslHandshake v0 和 FindCoordinator v0 取消废弃标记十一、Java 版本支持变化版本最低 Java推荐 Java说明3.2.3Java 8Java 11完整支持3.7.0Java 11Java 17Java 8 不再支持3.9.1Java 11Java 17/23Java 11 已废弃 (4.0 移除)3.9.1 新增:Java 23 支持JDK 23 编译器警告修复 (“this-escape” 警告)十二、升级路径建议12.1 从 3.2.3 升级到 3.9.1 的推荐路径# 路径 1: 直接滚动升级3.2.3 →3.3.x →3.4.x →3.5.x →3.6.x →3.7.x →3.8.x →3.9.0 →3.9.1# 路径 2: 跨版本升级 (建议不超过 2 个小版本)3.2.3 →3.4.x →3.6.x →3.8.x →3.9.1# 路径 3: ZooKeeper 到 KRaft 迁移3.2.3(ZK模式)→3.4.x →3.9.x(ZK模式)→ 执行 ZK 迁移 → KRaft 模式12.2 升级前检查清单验证 Java 版本兼容性 (至少 Java 11推荐 Java 17)检查废弃的 API 使用情况备份 ZooKeeper 数据 (如果仍在使用)检查自定义配置提供者兼容性验证第三方客户端兼容性准备 KRaft 迁移计划 (如果适用)测试环境充分验证12.3 关键配置变更配置项变更offsets.commit.required.acks3.8.0 废弃3.9.0 配置行为变更inter.broker.protocol.version升级后需要更新log.message.format.version升级后需要更新zookeeper.connectKRaft 模式不再需要十三、重要 KIP 索引13.1 架构相关KIP版本描述KIP-5003.0KRaft 元数据模式 (基础)KIP-8333.3.0KRaft 生产就绪标记KIP-8483.7下一代消费者再平衡协议KIP-8583.7.0KRaft 中 JBOD 支持KIP-8533.9.0动态 KRaft 仲裁成员管理13.2 分层存储KIP版本描述KIP-4053.6.0分层存储基础 (早期访问)KIP-9503.9.0分层存储禁用功能KIP-9563.9.0分层存储配额KIP-10053.9.0暴露本地和远程偏移量KIP-10573.9.0日志工具远程元数据支持13.3 Kafka StreamsKIP版本描述KIP-8893.5.0版本化状态存储KIP-8133.8.0可共享状态存储KIP-9243.8.0可自定义任务分配KIP-10333.9.0处理异常处理器13.4 Kafka ConnectKIP版本描述KIP-7103.5.0MM2 分布式模式完整支持KIP-8753.5.0Offset 管理原生支持KIP-4773.8.0PATCH 方法支持KIP-10173.9.0健康检查端点十四、迁移注意事项14.1 ZooKeeper 到 KRaft 迁移关键步骤:升级到 Kafka 3.4 (支持迁移工具)如果版本 2.4需要先升级到 3.4升级 ZooKeeper 到 3.8 (如果从旧版本迁移)升级到 Kafka 3.9 (最佳迁移版本)使用 kafka-migration.sh 执行迁移验证迁移成功停止 ZooKeeper重要提示:Kafka 3.9 是最后一个支持 ZooKeeper 的主要版本Kafka 4.0 将完全移除 ZooKeeper 支持14.2 Java 版本迁移Kafka 3.7: Broker 需要 Java 17客户端: 仍可使用 Java 11建议: 尽早迁移到 Java 17 或 Java 2114.3 分层存储迁移从 3.6 开始引入 (早期访问)3.9 正式生产就绪需要配置外部存储 (如 S3、GCS)十五、已知问题与限制15.1 3.2.3 已知问题KRaft 模式不稳定无分层存储ZooKeeper 强依赖旧版再平衡协议效率低15.2 3.9.1 已知限制静态元数据仲裁无法转换为动态仲裁KIP-848 仍在预览阶段部分旧 API 即将移除 (4.0)15.3 升级兼容性从到兼容性3.2.x3.9.x滚动升级支持3.2.x4.x需要经过 3.9十六、总结与建议16.1 主要变化总结架构层面: ZooKeeper 完全可选KRaft 生产就绪存储层面: 分层存储正式 GA流处理: Kafka Streams 大幅增强可观测性: 客户端指标和监控显著改进安全性: 多项安全增强和修复性能: 再平衡协议重构性能大幅提升16.2 升级建议立即升级理由:安全修复 (CVE-2022-34917 等)KRaft 生产就绪分层存储可用性能提升ZooKeeper 即将移除升级优先级:高优先级: 仍在使用 ZooKeeper 的集群中优先级: 需要 Java 17 支持的场景低优先级: 已在 3.6 的稳定集群16.3 未来规划Kafka 4.0:完全移除 ZooKeeper移除 Java 11 支持移除旧版 API建议行动:在 2025 年前完成到 3.9.x 的升级规划 ZooKeeper 到 KRaft 的迁移准备 Java 17/21 升级十七、参考资源官方文档Apache Kafka 官方网站Kafka 3.9.1 Release NotesKafka 3.2.3 Release Notes官方博客Apache Kafka 3.9.0 Release AnnouncementApache Kafka 3.8.0 Release AnnouncementApache Kafka 3.7.0 Release AnnouncementIntroducing Apache Kafka 3.5.0KIP 文档Kafka Improvement Proposals其他资源Confluent Kafka 文档Kafka 版本支持状态文档维护: 本文档基于 Apache Kafka 官方发布说明整理如有疑问请参考官方文档确认。