2020年8月10号,Kafka 2.5.1发行。
发行说明
自Kafka 2.5.0
版发布以来,Kafka 2.5.1
修复了72
个问题。有关更多信息,请阅读详细的发行说明。
以下是Kafka 2.5.1版本中解决JIRA问题的摘要,有关该版本的完整文档,入门指南以及关于该项目的信息,请参考Kafka官方文档,或kafka中文教程。
有关升级的注意事项:在升级你的集群之前,请仔细阅读此版本的升级文档。升级有关不兼容性和破坏性的变更,性能变化以及可能影响Kakfa生产的任何其他变化。
改善
[KAFKA-8938] - 连接-在结构验证期间改善内存分配
[KAFKA-9127] - GlobalKTables的不必要的组协调开销
[KAFKA-9216] - 在启动时强制连接内部主题配置
[KAFKA-9419] - 使用CircularIterator可能会发生整数溢出
[KAFKA-9468] - config.storage.topic分区计数问题很难调试
[KAFKA-9919] - 将日志添加到KafkaBasedLog
[KAFKA-9987] - 改进粘性分区分配器算法
Bug
[KAFKA-6647] - KafkaStreams.cleanUp在尝试清除的目录中创建.lock文件(Windows操作系统)
[KAFKA-8391] - 不稳定的测试RebalanceSourceConnectorsIntegrationTest#testDeleteConnector
[KAFKA-8661] - 不稳定的测试RebalanceSourceConnectorsIntegrationTest#testStartTwoConnectors
[KAFKA-8672] - RebalanceSourceConnectorsIntegrationTest#testReconfigConnector
[KAFKA-8869] - 尽管删除了任务,但KafkaConfigBackingStore中的map taskConfigs单调增长
[KAFKA-9298] - 重用映射的流会导致无效的拓扑
[KAFKA-9472] - 减少连接器的任务数量会导致已删除的任务显示为UNASSIGNED
[KAFKA-9533] - KStream#ValueTransform的JavaDocs错误
[KAFKA-9537] - 配置中的抽象转换会导致出现不友好的错误消息。
[KAFKA-9540] - 应用程序收到“关闭它时找不到待机任务0_4”错误
[KAFKA-9543] - 新细分受众群投放后,消费者补偿重置
[KAFKA-9570] - 无法为独立模式下的连接配置SSL
[KAFKA-9583] - OffsetsForLeaderEpoch请求有时不发送给分区负责人
[KAFKA-9625] - 无法描述通过IncrementalAlterConfigs设置的代理配置
[KAFKA-9633] - 未调用ConfigProvider.close()
[KAFKA-9654] - 如果先前的ReplicaAlterLogDirsThreadmeet遇到领导者时代错误,则无法再次创建ReplicaAlterLogDirsThread
[KAFKA-9667] - 连接JSON SERDE条形尾随零
[KAFKA-9669] - Kafka 2.4.0对Filebeat 5.6产生的数据的阻塞
[KAFKA-9675] - RocksDB指标始终报告为零
[KAFKA-9704] - z/OS不允许我们在mmap时调整文件大小
[KAFKA-9718] - 不要在请求日志中记录AlterConfigs请求的密码
[KAFKA-9724] - 消费者错误地忽略了提取的记录,因为它不再具有有效的位置
[KAFKA-9739] - StreamsBuilder.build失败,出现StreamsException“为OptimizableRepartitionNode找到了一个空的keyChangingChild节点”
[KAFKA-9763] -对Connect的InsertField的最新更改将无法在逻辑删除记录的键上插入字段
[KAFKA-9768] - 工作人员未正确处理rest.advertised.listener配置
[KAFKA-9802] - 修复片状系统测试`TransactionsTest.test_transactions`
[KAFKA-9826] - 当第一个脏偏移超过活动段的开始时,日志清理将反复选择相同的段而没有任何效果
[KAFKA-9830] - DeadLetterQueueReporter泄漏KafkaProducer实例
[KAFKA-9835] - 具有并发写入的竞争条件允许读取高水位线以上
[KAFKA-9839] - 当代理在控制器之后获悉其新纪元时,元数据更新将发生IllegalStateException
[KAFKA-9841] - 当工作人员加入旧代任务时,连接器和任务重复
[KAFKA-9845] - plugin.path属性不适用于配置提供程序
[KAFKA-9848] - 避免在任务分配失败但Connect worker仍在组中时触发计划的重新平衡延迟
[KAFKA-9849] - 解决了使用增量协作式重新平衡时worker.unsync.backoff.ms创建僵尸工人的问题
[KAFKA-9851] - 由于连接问题而吊销Connect任务也应清除正在运行的任务
[KAFKA-9854] - 重新认证会导致响应解析不匹配
[KAFKA-9863] - 将文档中不建议使用的--zookeeper选项更新为--bootstrap-server
[KAFKA-9883] - 重新启动任务的连接请求可能导致IllegalArgumentError:“ uriTemplate”参数为null
[KAFKA-9888] - REST扩展可以更改工作程序配置状态快照中的连接器配置
[KAFKA-9891] - 使用完全复制和备用副本进行任务迁移后,无效的状态存储内容
[KAFKA-9921] - 保留重复项时,WindowStateStore的缓存无法正常工作
[KAFKA-9922] - 更新示例自述文件
[KAFKA-9925] - 非关键KTable连接可能会导致融合模式注册表中的模式名称重复
[KAFKA-9950] - MirrorMaker2共享ConfigDef可能导致ConcurrentModificationException
[KAFKA-9955] - 从SinkTask :: close抛出的异常阴影其他异常
[KAFKA-9969] - ConnectorClientConfigRequest被隔离加载并抛出LinkageError
[KAFKA-9985] - 消耗DLQ主题的接收器连接器可能会耗尽代理
[KAFKA-9992] - EmbeddedKafkaCluster.deleteTopicAndWait无法与kafka_2.13一起使用
[KAFKA-9996] -将 zookeeper升级到3.5.8,以解决安全漏洞
[KAFKA-10004] - ConfigCommand在没有ZK的情况下无法找到默认代理配置
[KAFKA-10029] - 关闭通道时,不应修改Selector.completedReceives
[KAFKA-10030] - 从单个分区获取密钥时引发异常
[KAFKA-10049] - KTable-KTable外键联接抛出序列化异常
[KAFKA-10056] - 消费者元数据可能使用不包含新订阅主题的过期groupSubscription
[KAFKA-10066] - 在进行反序列化时,TopologyTestDriver没有考虑记录头
[KAFKA-10123] - 从旧的经纪商处获取时,消费者中的回归重置偏移量
[KAFKA-10134] - Kafka使用者升级到2.5后的重新平衡过程中的高CPU问题
[KAFKA-10173] - Kafka流升级期间的BufferUnderflowException
[KAFKA-10212] - 如果未经授权使用ListPartitionReassignments API,则无法使用TopicCommand描述主题
[KAFKA-10221] - 将KAFKA-9603的Backport修复为2.5
[KAFKA-10239] - DescribeGroup响应中的groupInstanceId字段应可忽略
[KAFKA-10254] - 当代理无法连接时,kafkaConsumer民意调查显示100%的CPU使用率
任务
[KAFKA-10185] - stream应在info级别记录摘要还原信息
测试
[KAFKA-10286] - 连接系统测试应等待工作人员加入小组
[KAFKA-10295] - ConnectDistributedTest.test_bounce 应该等待正常停止