2020年3月12号，Kafka 2.4.1发布。
以下是Kafka 2.4.1版本中解决JIRA问题的摘要，有关该版本的完整文档，入门指南以及关于该项目的信息，请参考Kafka官方文档，或kafka中文教程。
有关升级的注意事项：在升级你的集群之前，请仔细阅读此版本的升级文档。升级有关不兼容性和破坏性的变更，性能变化以及可能影响Kakfa生产的任何其他变化。
改进
[KAFKA-7052] - ExtractField SMT引发NPE - 优化错误消息
[KAFKA-9011] - 将 KStream#flatTransform 和 KStream#flatTransformValues 添加到Scala API
[KAFKA-9515] - 升级 ZooKeeper 到 3.5.7
Bug
[KAFKA-6266] - Kafka 1.0.0 : 重复WARN（警告），因为检查点offset 120955无效，所以将 __consumer_offsets-xx 的第一个脏offset重置为日志起始偏移量203569。(kafka.log.LogCleanerManager$)
[KAFKA-8025] - 片测试 RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapterTest#shouldForwardAllDbOptionsCalls
[KAFKA-8705] - 当两个MergeNode具有公共KeyChaingingNode时，topology优化会抛出NullPointerException
[KAFKA-8764] - LogCleanerManager无限循环压缩/清理segments
[KAFKA-8933] - 轮询事件中未处理的SSL握手异常 - 需要重试逻辑
[KAFKA-9024] - org.apache.kafka.connect.transforms.ValueToKey 导致 NPE
[KAFKA-9051] - 源任务源offset读取可能会阻止正常关闭
[KAFKA-9065] - 永久加载offset和组元数据循环
[KAFKA-9068] - 修复 JavaDocs `Stores.xxxSessionStore(...)`
[KAFKA-9074] - Connect的Values类不会从字符串文字中解析时间或时间戳记值
[KAFKA-9083] - Values类中的各种解析问题
[KAFKA-9143] - DistributedHerder误导连接器任务重新配置时记录错误
[KAFKA-9144] - 生产者状态的早到期可能导致协调epoch回退
[KAFKA-9192] - NullPointerException如果架构中的字段不存在于值中
[KAFKA-9204] - 遇到逻辑删除事件时，ReplaceField转换失败
[KAFKA-9232] - 协调器新成员心跳完成不适用于JoinGroup v3
[KAFKA-9235] - StopReplica请求后未清除事务状态
[KAFKA-9254] - 动态更新Kafka Broker配置两次，将日志配置恢复为默认值
[KAFKA-9293] - 带 --offsets-decoder 的 DumpLogSegments中的NPE
[KAFKA-9306] - 关闭后，Kafka Consumer不会清除所有指标
[KAFKA-9307] - ZK会话超时后，事务协调器可能处于未知状态
[KAFKA-9310] - StreamThread可能死于可恢复的UnknownProducerId异常
[KAFKA-9335] - java.lang.IllegalArgumentException: 分区数必须小于1。
[KAFKA-9390] - KTable的非关键连接与融合的Avro Serdes不兼容
[KAFKA-9449] - 生产者的BufferPool可能会阻塞生产者关闭。
[KAFKA-9491] - 重新分配期间的快速选举可能导致副本获取程序失败
[KAFKA-9492] - 产生记录级错误的ProducerResponse与较旧的客户端版本一起引发NPE
[KAFKA-9500] - 外键Join创建无效的topology
[KAFKA-9503] - TopologyTestDriver以错误的顺序处理中间结果
[KAFKA-9507] - AdminClient应该检查是否缺少提交offset
[KAFKA-9517] - 没有Materialized参数的KTable连接会产生进一步连接NPE的结果
[KAFKA-9535] - 消费者遇到FENCED_LEADER_EPOCH时未更新元数据
[KAFKA-9540] - 应用程序获取“Could not find the standby task 0_4 while closing it”错误
[KAFKA-9599] - 创建唯一的sensor来记录组重新平衡
[KAFKA-9601] - worker记录原始连接器配置，包括值
