Kafka 3.7.0版本发布说明

半兽人 发表于: 2024-03-11   最后更新时间: 2024-03-19 23:06:07  
{{totalSubscript}} 订阅, 391 游览

2024年2月27日,Kafka 3.7.0发布。

以下是Kafka 3.7.0版本中解决JIRA问题的摘要,有关该版本的完整文档,入门指南以及关于该项目的信息,请参考Kafka官方文档,或kafka中文教程。

有关升级的注意事项:在升级你的集群之前,请仔细阅读此版本的升级文档。升级有关不兼容性和破坏性的变更,性能变化以及可能影响Kakfa生产的任何其他变化。

新功能

[KAFKA-9800] - [KIP-580] 客户端指数回退
[KAFKA-15215] - default.dsl.store 配置与自定义状态存储不兼容
[KAFKA-15428] - Connect 的集群范围动态日志调整
[KAFKA-15445] - KIP-975: Apache KafkaDocker 镜像
[KAFKA-15448] - Streams StandbyTaskUpdateListener
[KAFKA-15470] - 允许在停止状态下创建连接器

改进

[KAFKA-9693] - 滚动时刷新日志段导致的 Kafka 延迟峰值
[KAFKA-10199] - 将状态恢复分离到不同的线程中
[KAFKA-14127] - KIP-858: 在 KRaft 中处理 JBOD broker磁盘故障
[KAFKA-14780] - 使刷新HttpsJwksTest#testSecondaryRefreshAfterElapsedDelay确定性
[KAFKA-14855] - 加强断言连接器被删除的集成测试逻辑
[KAFKA-14912] - 引入远程索引缓存大小的配置,最好是动态配置。
[KAFKA-15022] - 支持 Kafka 流中的机架感知任务分配
[KAFKA-15046] - 在高磁盘负载下产生性能问题
[KAFKA-15047] - 启用分层存储时,当活动分段的保留时间被突破时处理滚动分段。
[KAFKA-15141] - log4j2 的 CPU 使用率高
[KAFKA-15147] - 衡量待处理和未处理的远程分段操作
[KAFKA-15208] - 将 Jackson 依赖项升级至 2.16.0 版
[KAFKA-15241] - 通过将各自的epochs保留在范围内来计算分层offset。
[KAFKA-15248] - 将 BooleanConverter 添加到 Kafka Connect
[KAFKA-15273] - 记录过期客户端证书的通用名称
[KAFKA-15315] - 使用 getOrDefault 而不是 get
[KAFKA-15401] - 索引损坏的段不应上传到远程存储
[KAFKA-15415] - 在 Java 客户端中,应跳过回退以重试新leader的生产者批次
[KAFKA-15418] - 更新减压位置声明
[KAFKA-15432] - RLM Stop 分区不应该被非分层存储top调用
[KAFKA-15464] - 允许动态重新加载具有不同 DN / SAN 的证书
[KAFKA-15471] - 允许独立停止 KRaft 控制器或代理
[KAFKA-15476] - 提高 checkstyle 性能
[KAFKA-15485] - 支持使用 Java 21 构建(LTS 版本)
[KAFKA-15492] - 使用 Java 21 构建时启用spotbugs
[KAFKA-15493] - Ensure system tests work with Java 21
[KAFKA-15493] - 确保系统测试用于Java 21
[KAFKA-15521] - 重构 build.gradle 以使 gradle swagger 插件与 swagger 依赖项保持一致
[KAFKA-15527] - 在 IQv2 中添加对 kv-store 的reverseRange和reverseAll查询
[KAFKA-15536] - 动态调整远程索引缓存的大小
[KAFKA-15542] - 释放错误的成员分配
[KAFKA-15563] - 当 Connect REST 请求超时时提供信息性错误消息
[KAFKA-15566] - KRaft 模式下 FetchRequestTest.scala 中的不稳定测试
[KAFKA-15596] - 将 ZooKeeper 升级到 3.8.3
[KAFKA-15629] - 引入 IQv2 查询类型的提案:TimestampedKeyQuery 和 TimestampedRangeQuery
[KAFKA-15685] - 添加 MinGW 和 MSYS2 (Windows) 缺少的兼容性
[KAFKA-15769] - 修复错误日志并出现异常
[KAFKA-15774] - Respect default.dsl.store Configuration Without Passing it to StreamsBuilder
[KAFKA-15774] - 尊重 default.dsl.store 配置而不将其传递给 StreamsBuilder
[KAFKA-15831] - 列出客户端指标配置资源
[KAFKA-15837] - 使用 Consumer.poll 时抛出错误(长时间超时)
[KAFKA-15866] - 重构 OffsetFetchRequestState 错误处理以与 OffsetCommitRequestState 更加一致
[KAFKA-15868] - KIP-951 - 客户端的Leader发现优化
[KAFKA-15906] - 对于低吞吐量/有限分区,比 offset.lag.max 更频繁地发出offset同步
[KAFKA-15922] - 添加 JBOD 的元数据版本
[KAFKA-15971] - 为新消费者重新启用消费者集成测试
[KAFKA-15980] - 添加 KIP-1001 CurrentControllerId 指标
[KAFKA-16007] - 对于大型集群,ZK 迁移可能会很慢
[KAFKA-16210] - 将 jose4j 升级到 0.9.4

Bug

[KAFKA-12679] - 重新平衡正在恢复或运行的任务可能会导致新创建的任务出现目录活锁现象
[KAFKA-13327] - 连接器的预检验证导致 500 个响应
[KAFKA-13973] - block-cache-capacity指标的值是正常值的两倍
[KAFKA-13988] - Mirrormaker 2 auto.offset.reset=latest 无效
[KAFKA-14067] - Sink 连接器的 override.consumer.group.id 可能与 worker group.id 冲突
[KAFKA-14616] - 使用离线代理重新创建主题会导致永久 URP
[KAFKA-14767] - Gradle 编译失败,因为 git gc 后缺少 commitId
[KAFKA-14927] - 防止 kafka-configs.sh 设置非字母数字的配置键名
[KAFKA-15000] - 在 jackson-core 中报告了高危漏洞 PRISMA-2023-0067
[KAFKA-15117] - SslTransportLayerTest.testValidEndpointIdentificationCN 在 Java 2021 中失败
[KAFKA-15152] - 修复格式化字符串时格式指定不正确的问题
[KAFKA-15221] - 来自重启追随者的请求之间的潜在竞赛条件
[KAFKA-15230] - 控制器之间的 ApiVersions 数据不可靠
[KAFKA-15311] - 修复关于在 KRaft 迁移期间恢复到 ZooKeeper 模式的文档
[KAFKA-15372] - MM2 滚动重启可以静默删除配置更改
[KAFKA-15392] - RestServer 启动但不停止 ServletContextHandler
[KAFKA-15412] - 读取未知版本的仲裁状态文件应触发错误
[KAFKA-15465] - 当 MM2 的内部主题是在不允许创建主题的集群上预先创建时,MM2 无法工作
[KAFKA-15473] - 连接连接器插件端点显示重复的插件
[KAFKA-15481] - RemoteIndexCache 中的并发错误导致 IOException
[KAFKA-15489] - KRaft 集群中的脑裂
[KAFKA-15491] - 运行 WordCountDemo 时出现 RackId 不存在错误
[KAFKA-15500] - SslPrincipalMapper.java 中的代码错误
[KAFKA-15502] - 在 SslEngineValidator 中处理大型密钥库
[KAFKA-15507] - adminClient 在关闭实例时不应抛出可重试的异常
[KAFKA-15510] - 当获取响应没有记录时,追随者的 lastFetchedEpoch 错误设置
[KAFKA-15511] - 如果 indexFile 损坏,则无法正确处理异常。
[KAFKA-15537] - 不支持不安全的元数据版本降级
[KAFKA-15571] - StateRestoreListener#onRestoreSuspished 永远不会被调用,因为包装器 DelegatingStateRestoreListener 未实现 onRestoreSuspished
[KAFKA-15602] - 3.4.0 ByteBufferSerializer 中的重大更改
[KAFKA-15605] - ZK 中标记为删除的Topic被错误地迁移到 KRaft
[KAFKA-15607] - MirrorCheckpointTask 中抛出可能的 NPE
[KAFKA-15644] - 修复 netty:handler 中的 CVE-2023-4586
[KAFKA-15653] - ChunkedByteStream 中的 NPE
[KAFKA-15658] - Zookeeper.jar | CVE-2023-44981
[KAFKA-15680] - 在Co-operative Rebalancing(ICR)模式的重新平衡中,Partition-Count没有得到正确更新
[KAFKA-15689] - 当预期状态错误时,KRaftMigrationDriver 未记录跳过事件
[KAFKA-15693] - 在连接中禁用预定的再平衡延迟会导致无限期地未分配连接器和任务
[KAFKA-15695] - 重建远程日志辅助状态后,追随者上的本地日志启动偏移未更新
[KAFKA-15704] - 控制器注册请求必须酌情设置 ZkMigrationReady 字段
[KAFKA-15755] - LeaveGroupResponse v0-v2 应处理无成员问题
[KAFKA-15771] - ProduceRequest#partitionSizes() 不是原子操作
[KAFKA-15799] - ZK broker错误地处理 KRaft 元数据快照
[KAFKA-15800] - 畸形的连接源offset会导致其他分区出现数据异常
[KAFKA-15802] - 尝试访问 listOffsets 上未复制的分段元数据
[KAFKA-15817] - 如果有多个地址可用,避免重新连接到相同的 IP 地址
[KAFKA-15819] - 当启用ZK迁移时,KafkaServer会泄露KafkaRaftManager。
[KAFKA-15824] - SubscriptionState 的 maybeValidatePositionForCurrentLeader 应该处理尚未订阅的分区
[KAFKA-15825] - KRaft 控制器在迁移后将空状态写入 ZK
[KAFKA-15836] - KafkaConsumer 订阅多个Topic时不尊重 max.poll.records
[KAFKA-15860] - ControllerRegistration必须写入元数据镜像
[KAFKA-15888] - DistributedHerder 日志上下文默认情况下不应在每个 Connect Worker 上使用相同的客户端 ID
[KAFKA-15890] - 超时较长的 Consumer.poll 不知道已分配的分区
[KAFKA-15904] - 降级测试在使用 directory.id 时失败 
[KAFKA-15932] - 漏洞测试 - PlaintextConsumerTest.testSeek("kraft+kip-848", "consumer")
[KAFKA-15946] - AsyncKafkaConsumer 应在应用程序线程上重试提交,而不是自动重试
[KAFKA-15965] - 测试失败:org.apache.kafka.common.request.BrokerRegistrationRequestTest
[KAFKA-15967] - 修复对账逻辑中的撤销问题
[KAFKA-15978] - 新消费者以空成员 ID 发送 OffsetCommit
[KAFKA-15986] - 新消费者组协议集成测试失败
[KAFKA-16005] - 从 ZooKeeper 迁移到 KRaft 的回滚中缺少在代理上禁用控制器和迁移配置的功能
[KAFKA-16012] - 消费者中不完整的范围分配
[KAFKA-16015] - kafka-leader-election 超时值总是被默认值覆盖
[KAFKA-16017] - 恢复任务时,检查点偏移不正确
[KAFKA-16029] - 调查日志中 "无法找到 X 节点的 FetchSessionHandler "的原因
[KAFKA-16046] - 恢复后出现反序列化异常时,流流连接失败
[KAFKA-16078] - 在获取最新 MetadataVersion 方面更加一致
[KAFKA-16085] - 远程复制滞后的字节/段指标不会更新所有主题值
[KAFKA-16094] - BrokerRegistrationRequest.logDirs 字段必须可忽略
[KAFKA-16101] - KRaft 迁移回滚文档不正确
[KAFKA-16120] - 修复 ZK 迁移过程中的分区重新分配问题
[KAFKA-16131] - 在元数据版本为 3.6 的情况下运行 Kafka 3.7.0-RC2 KRaft 集群时重复出现 UnsupportedVersionException 日志
[KAFKA-16133] - 调节期间的提交总是超时
[KAFKA-16141] - StreamsStandbyTask##test_standby_tasks_rebalanceArguments:{} 在 3.7 中持续失败
[KAFKA-16144] - 控制器领导者 checkQuorum 定时器应该只跳过 1 个控制器的情况
[KAFKA-16157] - 使用脱机磁盘的主题再现无法正确更新领导/收缩 ISR
[KAFKA-16162] - 升级到 3.7 后,新创建的主题不可用
[KAFKA-16216] - 在 ZK 迁移过程中减少初始元数据加载的批次大小
[KAFKA-16221] - 来自生产者的非法状态异常

任务

[KAFKA-14438] - 当 consumer 为 AsyncKafkaConsumer 配置空/仅限空白的 group.id 时抛出错误
[KAFKA-15093] - 将 3.5.0 添加到broker/client和流升级/兼容性测试
[KAFKA-15378] - 滚动升级系统测试失败
[KAFKA-15479] - 应考虑一次远程日志段是否存在保留违规
[KAFKA-15535] - 添加“remote.log.index.file.cache.total.size.bytes”配置属性的文档。
[KAFKA-15661] - KIP-951:服务器端和协议更改
[KAFKA-15664] - 添加 3.4.0 流升级/兼容性测试
[KAFKA-15714] - DynamicNumNetworkThreadsTest 中的 KRaft 支持
[KAFKA-15725] - FetchRequestTest 中的 KRaft 支持
[KAFKA-15730] - ProducerFailureHandlingTest 中的 KRaft 支持
[KAFKA-15731] - ListOffsetsIntegrationTest 中的 KRaft 支持
[KAFKA-15732] - LogAppendTimeTest 中的 KRaft 支持
[KAFKA-15733] - FetchRequestMaxBytesTest 中的 KRaft 支持
[KAFKA-15765] - 删除任务级别指标“commit-latency”

测试

[KAFKA-15169] -RemoteIndexCache 添加测试
[KAFKA-15179] - 增加 FileStream SinkSource 连接器的集成测试
[KAFKA-15439] - 增加启用分层存储的事务测试
[KAFKA-15547] - MirrorMakerConfigTest#testClientConfigProperties 中的线程泄漏
[KAFKA-15659] - 测试 RestoreIntegrationTest.shouldInvokeUserDefinedGlobalStateRestoreListener 出错
[KAFKA-15671] - 错误的测试 RemoteIndexCacheTest.testClearCacheAndIndexFilesWhenResizeCache
[KAFKA-15780] - 在测试中创建主题时等待一致的牛皮纸元数据
[KAFKA-15793] - 脆弱的测试 ZkMigrationIntegrationTest.testMigrateTopicDeletions
[KAFKA-15991] - 脆弱的新消费者测试 testGroupIdNotNullAndValid
[KAFKA-16035] -ExpiresPerSecRemoteLogSizeComputationTime 指标添加集成测试
[KAFKA-16139] - StreamsUpgradeTest 在 3.7.0 中持续失败

子任务

[KAFKA-14247] - 为 Consumer 实现 EventHandler 接口和 DefaultEventHandler
[KAFKA-14252] - 为新的消费者线程模型创建后台线程骨架
[KAFKA-14274] - 引入 FetchRequestManager 以将获取集成到新的消费者线程重构中
[KAFKA-14481] - 将 LogSegment/LogSegments 移至存储模块
[KAFKA-14499] - 实现 OffsetFetch/OffsetCommit API
[KAFKA-14502] - 实现 LeaveGroup API
[KAFKA-14503] - 实现 ListGroups
[KAFKA-14515] - 实现优化的统一代理侧分配器
[KAFKA-14516] - 实现静态成员资格
[KAFKA-14519] - 为新的协调器添加度量标准
[KAFKA-14581] - 将 GetOffsetShell 移到工具中
[KAFKA-14593] - 将领袖选举命令移至工具中
[KAFKA-14595] - 将重新分配分区命令移至工具中
[KAFKA-14596] - 移动 TopicCommand 到工具
[KAFKA-14675] - 从 Fetcher 中提取元数据相关任务到 MetadataFetcher 中
[KAFKA-14684] - 在 WorkerSinkTaskThreadedTest 中使用 Mockito 替换 EasyMock 和 PowerMock
[KAFKA-14724] - 将 FetcherTest 中的测试移植到 FetchRequestManagerTest 中
[KAFKA-14875] - 实现 Wakeup()
[KAFKA-14960] - 元数据请求管理器和 listTopics/partitionsFor API
[KAFKA-14965] - 引入 OffsetsRequestManager 以将 ListOffsets 请求集成到新的消费者线程重构中
[KAFKA-14987] - 实现组/偏移过期
[KAFKA-15026] - 实现同一子拓扑的最小成本流量平衡任务
[KAFKA-15061] - 协调器分区写入器应重复使用缓冲区
[KAFKA-15081] - 实现新的消费者时间偏移量(consumer offsetsForTimes
[KAFKA-15115] - 在偏移量请求管理器中实现重置位置功能
[KAFKA-15158] - 添加 RemoteDeleteRequestsPerSec、RemoteDeleteErrorsPerSec、BuildRemoteLogAuxStateRequestsPerSec、BuildRemoteLogAuxStateErrorsPerSec 的度量指标
[KAFKA-15163] - 为新的 KafkaConsumer 实现 validatePositions 功能
[KAFKA-15164] - 从 OffsetsForLeaderEpochClient 中提取可重复使用的逻辑
[KAFKA-15174] - 确保正确的线程正在执行回调
[KAFKA-15184] - 重构和清理新的消费者内部结构
[KAFKA-15188] - 实现更多剩余的 PrototypeAsyncConsumer API
[KAFKA-15200] - 在 release.py 开始时验证先决条件
[KAFKA-15237] - 实现写操作超时
[KAFKA-15275] - 实现消费者群体成员状态机
[KAFKA-15276] - 实现 ConsumerRebalanceListener 回调的事件管道
[KAFKA-15277] - 设计和实现对内部消费者委托的支持
[KAFKA-15278] - 为 KIP-848 ConsumerGroupHeartbeat 协议 RPC 实施客户端支持
[KAFKA-15280] - 实现对选择 KIP-848 服务器端分配器的客户端支持
[KAFKA-15281] - 实现 groupMetadata 消费者 API
[KAFKA-15304] - 当消费者关闭时,CompletableApplicationEvents 没有完成
[KAFKA-15306] - 更新获取位置时整合已提交的偏移逻辑
[KAFKA-15316] - CommitRequestManager 未调用 RequestState 回调
[KAFKA-15317] - 多消费者异步访问已提交偏移量的问题修复
[KAFKA-15327] - 客户端消费者应在关闭时提交偏移量
[KAFKA-15346] - 使用版本化状态存储的单键单时间戳 IQ
[KAFKA-15347] - 具有版本控制状态存储的单密钥多时间戳 IQ
[KAFKA-15355] - 消息模式更改
[KAFKA-15358] - QueuedReplicaToDirAssignments 公制
[KAFKA-15365] - 代理端副本管理变更
[KAFKA-15366] - 日志目录失败集成测试
[KAFKA-15438] - 审查异步消费者中用于重置/验证位置的异常缓存逻辑
[KAFKA-15454] - 在管理员客户端中添加对第 9 版 OffsetCommit 的支持
[KAFKA-15455] - 在消费者中添加对第 9 版 OffsetCommit 的支持
[KAFKA-15456] - 在消费者中添加对 OffsetFetch 版本 9 的支持
[KAFKA-15457] - 在管理中添加对 OffsetFetch 版本 9 的支持
[KAFKA-15461] - 为 ListGroup API 添加集成测试
[KAFKA-15484] - 实现通用的统一代理侧分配器
[KAFKA-15508] - 方法总是返回相同的值 ApplicationEventProcessor.java
[KAFKA-15531] - 确保在断开连接异常时移除协调器节点
[KAFKA-15533] - 确保 HeartbeatRequestManager 只发送一次某些字段
[KAFKA-15534] - 向请求处理程序传播超时时的客户端响应时间
[KAFKA-15544] - 为新协议启用现有客户端集成测试
[KAFKA-15548] - 在 Consumer.close() 时发送 GroupConsumerHeartbeatRequest
[KAFKA-15550] - 在新消费者中对负时间戳进行 OffsetsForTimes 验证
[KAFKA-15554] - 更新客户端状态机以与一次发送一个分配的协议保持一致
[KAFKA-1555] - 确保在 PrototypeAsyncConsumer.poll() 中正确处理唤醒。
[KAFKA-15562] - 确保获取偏移量和提交偏移量处理程序同时处理超时和各种错误类型
[KAFKA-15574] - 更新会员管理器状态机的状态和转换
[KAFKA-15582] - 清理关闭检测,代理端
[KAFKA-15593] - 在代理/客户端升级/兼容性测试中添加 3.6.0
[KAFKA-15594] - 在流升级/兼容性测试中添加 3.6.0
[KAFKA-15598] - 为 DescribeGroups API、DeleteGroups API 和 OffsetDelete API 添加集成测试
[KAFKA-15604] - 添加遥测 RPC 定义
[KAFKA-15613] - 在接口和客户端配置中添加客户端 API。
[KAFKA-15614] - 定义用于捕获遥测指标的接口/类
[KAFKA-15616] - 定义客户端遥测状态及其转换
[KAFKA-15618] - 实现以 OTLP 格式收集指标的 MetricsCollector
[KAFKA-15628] - 重构 ConsumerRebalanceListener 调用以实现重复使用
[KAFKA-15633] - Bug:生成的持久目录 ID 在启动时被覆盖。
[KAFKA-15643] - 改进卸载日志记录
[KAFKA-15645] - 将 ReplicationQuotasTestRig 移到工具中
[KAFKA-15647] - 修复新旧组协调器在错误处理中的不同行为
[KAFKA-15663] - 实现管理遥测生命周期的 ClientTelemetryReporter
[KAFKA-15668] - 添加带阴影类的 Opentelemetry Proto 库
[KAFKA-15669] - 实施遥测命名策略
[KAFKA-15673] - 定义新的 client_metrics 资源类型配置以存储度量配置。
[KAFKA-15679] - 客户端支持新的消费者配置
[KAFKA-15681] - 在 kafka-configs.sh 中添加对客户端度量的支持
[KAFKA-15684] - 增加通过实用程序描述所有订阅的支持
[KAFKA-15696] - 在 Consumer.close() 时撤销分区
[KAFKA-15705] - 为 Heartbeat API 和 GroupLeave API 添加集成测试
[KAFKA-15775] - 为 AsyncKafkaConsumer 实现 listTopics() 和 partitionFor()
[KAFKA-15778] - 实现 ClientMetricsManager 以处理请求
[KAFKA-15779] - 定义代理配置和异常
[KAFKA-15794] - 实现遥测 API 的请求和响应处理
[KAFKA-15803] - 在提交过程中更新最后看到的纪元
[KAFKA-15818] - 实现最大轮询间隔
[KAFKA-15830] - 在 KafkaApis 中添加请求/响应处理并更新度量插件
[KAFKA-15833] - 限制只能在一个线程中使用消费者 API
[KAFKA-15842] - 正确处理新消费者的 KafkaConsumer.committed
[KAFKA-15849] - 修正运行时分区大小为零时的 ListGroups API
[KAFKA-15854] - 将 Java 类从 kafka.server 移至服务器模块
[KAFKA-15856] - 为 JoinGroup API 和 SyncGroup API 添加集成测试
[KAFKA-15865] - 确保 consumer.poll() 执行自动提交回调
[KAFKA-15870] - 将 Yammer 中新的群组协调员指标移至 Metrics 中
[KAFKA-15871] - 实现 kafka-client-metrics.sh 工具
[KAFKA-15874] - 为过时的请求 api 版本添加度量和请求日志属性 (KIP-896)
[KAFKA-15879] - 为 Docker 映像添加文档和示例
[KAFKA-15880] - 添加用于推广 RC docker 镜像的 github 操作工作流
[KAFKA-15881] - 更改发布流程维基和发布流程
[KAFKA-15883] - 实现 RemoteCopyLagBytes
[KAFKA-15887] - 关闭过程中的自动提交总是在后台线程中出现异常失败
[KAFKA-15893] - 提高目录分配的 MetadataVersion
[KAFKA-15901] - 实施客户端变更以支持遥测 API
[KAFKA-15903] - 为构建和推送 RC Docker Image 添加 github 操作工作流
[KAFKA-15910] - 新的组协调器需要在加载时生成快照
[KAFKA-15913] - 从 ConsumerTestBuilder 迁移 AsyncKafkaConsumerTest
[KAFKA-15953] - 重构轮询延迟
[KAFKA-15981] - 仅在组大小发生变化时更新组大小
[KAFKA-16002] - 实现 RemoteCopyLagSegments、RemoteDeleteLagBytes 和 RemoteDeleteLagSegments
[KAFKA-16013] - 实现 ExpiresPerSec 度量
[KAFKA-16014] - 实现 RemoteLogSizeComputationTime、RemoteLogSizeBytes、RemoteLogMetadataCount
[KAFKA-16026] - 异步消费者不会向后台线程发送轮询事件
[KAFKA-16030] - 新组协调器应检查分区是否在加载期间离线
[KAFKA-16036] - 添加`组协调器重新平衡协议`并发布所有新配置
[KAFKA-16040] - 将 `Generic` 重命名为 `Classic`
[KAFKA-16053] - 修复默认目录服务泄露问题
[KAFKA-16058] - 修复控制器 API 测试中的泄漏问题
[KAFKA-16059] - 修复了 :core:test 中 ExpirationReaper-1-AlterAcls 线程的泄漏问题
[KAFKA-16062] - 升级 mockito 至 5.8.0
[KAFKA-16065] - 修复延迟操作测试中的漏洞
[KAFKA-16074] - 修复复制管理器测试中的线程泄漏问题
[KAFKA-16079] - 修复 LocalLeaderEndPointTest/FinalizedFeatureChangeListenerTest/KafkaApisTest/ReplicaManagerConcurrencyTest 中的漏洞
[KAFKA-16099] - 处理 AsyncKafkaConsumer.commitSync 的超时问题
[KAFKA-16118] - 当副本被删除时,协调器卸载失败

REF

https://downloads.apache.org/kafka/3.7.0/RELEASE_NOTES.html

更新于 2024-03-19

查看kafka更多相关的文章或提一个关于kafka的问题,也可以与我们一起分享文章