2021年9月17日，Kafka 2.8.1发布。
Kafka 2.8.1修复了自2.8.0版本以来的49个问题。
以下是Kafka 2.8.0版本中解决JIRA问题的摘要，有关该版本的完整文档，入门指南以及关于该项目的信息，请参考Kafka官方文档，或kafka中文教程。
有关升级的注意事项：在升级你的集群之前，请仔细阅读此版本的升级文档。升级有关不兼容性和破坏性的变更，性能变化以及可能影响Kakfa生产的任何其他变化。
新功能
[KAFKA-13207] - 如果从 fetcher 中删除了分区，则副本 fetcher 不应在分歧的时候更新分区状态
改进
[KAFKA-10675] - 来自 ConnectSchema.validateValue() 的错误消息应包括架构的名称。
[KAFKA-13209] - 升级 jetty-server 以修复 CVE-2021-34429
[KAFKA-13258] - AlterClientQuotas 响应失败时不包含错误
[KAFKA-13259] - 当DescribeProducers 响应失败时不包含错误。
Bug
[KAFKA-8562] - 尽管有 KAFKA-5051，SASL_SSL 仍然执行反向 DNS 查找
[KAFKA-9747] - 没有为连接器创建任务
[KAFKA-9887] - 如果任务在启动期间失败，则失败任务计数 JMX 指标不会更新
[KAFKA-10340] - 尝试为不存在的topic生产消息时候，如果不是永远挂起的话，源连接器应报告错误
[KAFKA-12252] - 当worker失去领导权时，分布式herder tick线程快速的轮询
[KAFKA-12262] - 当拥有key的follower成为leader时，新的会话密钥不会被分发。
[KAFKA-12336] - 在调用带有命名的Consumed参数的`stream[K, V](topicPattern: Pattern)`API时，自定义流的命名不起作用。
[KAFKA-12619] - 确保在初始化高水位之前提交LeaderChange消息
[KAFKA-12667] - 关闭StateDirectory时错误日志不正确
[KAFKA-12672] - 运行test-kraft-server-start的结果是错误的
[KAFKA-12702] - 在InterBrokerSendThread中捕获的未处理的异常
[KAFKA-12730] - 从Java 9开始，单次Kerberos登录失败会导致所有未来连接失败
[KAFKA-12747] - 片段测试RocksDBStoreTest.shouldReturnUUIDsWithStringPrefix
[KAFKA-12749] - 更改日志topic配置在被抑制的KTable上丢失
[KAFKA-12751] - 如果提议的状态与实际状态相同，ISR将保持在飞行状态中
[KAFKA-12752] - CVE-2021-28168 升级jersey到2.34或3.02
[KAFKA-12835] - broker 上的 Topic ID 可能不匹配（broker之间协议版本更新后）
[KAFKA-12870] - RecordAccumulator 卡在刷新状态
[KAFKA-12890] - 消费者组陷入`CompletingRebalance`
[KAFKA-12898] - 订阅中拥有的分区必须排序
[KAFKA-12904] - Connect 的验证 REST 端点使用了不正确的超时
[KAFKA-12914] - StreamSourceNode.toString() 与 StreamsBuilder.stream(Pattern) ctor 一起抛出
[KAFKA-12925] - 中间接口缺少prefixScan
[KAFKA-12948] - 节点处于连接状态的 NetworkClient.close(node) 使 NetworkClient 无法使用
[KAFKA-12951] - 在恢复GlobalKTable时无限循环
[KAFKA-12983] - onJoinPrepare并不总是在加入组之前被调用。
[KAFKA-12984] - Cooperative粘性分配器可能会因无效的 SubscriptionState 输入元数据而卡住
[KAFKA-12991] - 修正对`AbstractCoordinator.state`的不安全访问
[KAFKA-12996] - 当获取的偏移量小于leader的起始偏移量时，对于分歧的时候没有正确处理OffsetOutOfRange。
[KAFKA-13007] - KafkaAdminClient getListOffsetsCalls 为每个topic分区构建集群快照
[KAFKA-13037] - "线程状态已经是PENDING_SHUTDOWN"日志垃圾
[KAFKA-13081] - 端口粘性分配器的修复（KAFKA-12984）退回到2.8版本
[KAFKA-13092] - LISR请求中的性能回归
[KAFKA-13096] - 当线程被添加/删除/替换时，QueryableStoreProvider不被更新，导致IQ无法实现。
[KAFKA-13099] - 过期的transactionalIds时消息太大错误
[KAFKA-13141] - 如果存在分歧时，leader不应更新follower的获取偏移量
[KAFKA-13214] - 消费者不应该在断开连接后重置组的状态
[KAFKA-13231] - `TransactionalMessageCopier.start_node`应该等待，直到进程完全启动。
[KAFKA-13236] - TopologyTestDriver在EOS-beta配置下崩溃了
[KAFKA-13277] - 请求/响应中长字符串的序列化抛出BufferOverflowException
任务
[KAFKA-12820] - 升级 maven-artifact 依赖以解决 CVE-2021-26291 问题
[KAFKA-12976] - 从删除主题的调用中移除 UNSUPPORTED_VERSION 错误
[KAFKA-12985] - CVE-2021-28169 - 升级jetty版本到9.4.42
子任务
[KAFKA-12790] - 移除SslTransportLayerTest.testUnsupportedTlsVersion
