Apache Kafka 2.6.1 发布，分布式消息发布订阅系统

Apache Kafka 2.6.1 已经发布，这是一个 bug 修复版本，它包括 41 个 JIRA 的修复和改进。

主要更新内容包括：

Improvement

• [ KAFKA-10122 ]- Consumer 在 rebalance 时也应允许 heartbeat
• [ KAFKA-10309 ]- KafkaProducer 的 sendOffsetsToTransaction 不应无限期地阻塞
• [ KAFKA-10802 ]- 启动 consumers 时出现虚假日志消息

Bug

• [ KAFKA-8033 ]- Flaky Test PlaintextConsumerTest＃testFetchInvalidOffset
• [ KAFKA-8630 ]- 使用 WindowStore 对流处理器进行单元测试会抛出 ClassCastException
• [ KAFKA-9584 ]- 删除 headers 会导致 ConcurrentModificationException
• [ KAFKA-9666 ]- 无法重置 Transactional producer Epoch
• [ KAFKA-10134 ]- Kafka consumer 升级到 2.5 后的重新平衡过程中的高 CPU 问题
• [ KAFKA-10188 ]- 任务停止后会调用 Sink task preCommit 方法
• [ KAFKA-10218 ]- DistributedHerder 的 canReadConfigs 字段永远不会被重置为 true
• [ KAFKA-10271 ]- 从单个分区获取密钥时的性能下降
• [ KAFKA-10282 ]- 如果日志被删除并重新创建的速度足够快，则日志指标会被删除
• ......

完整更新内容查看：https://downloads.apache.org/kafka/2.6.1/RELEASE_NOTES.html