Apache Kafka 2.7.0 于2020年12月21日正式发布，这个版本是目前 Kafka 最新稳定版本，大家可以根据需要自行决定是否需要升级到次版本，关于各个版本升级到 Apache Kafka 2.7.0 请参见《Upgrading to 2.7.0 from any version 0.8.x through 2.6.x》。Apache Kafka 2.7.0 新版本的下载地址为：

https://kafka.apache.org/downloads

在这个版本中，社区仍然在推进从 Kafka 移除对 ZooKeeper 的依赖，比如这个版本在 KIP-497 里面添加了可以修改 ISR 的 Broker 内部 API；在 KIP-500 里面增加了自元数管理（Self-Managed Metadata Quorum）的 Raft 核心实现，这个也是去掉 Zookeeper 的一部分工作。现在在 Kafka 的源代码里面有一个名为 raft 的模块专门用于实现共识协议（consensus protocol）。在与控制器（Kafka 集群中负责管理分区和副本状态的 broker）的集成完成之前，有一个独立的服务器可以用来测试 Raft 实现的性能。

当然，为了取代 Zookeeper，还有更多的工作正在努力进行中，很多 KIP 正在积极开发中，以使得每个集群能够支持更多的分区、更简单的操作和更严格的安全性。

分级存储（Tiered Storage）工作也正在继续进行中，这个可以参见 KIP-405。

Kafka 2.7.0 包括以下特征：

Configurable TCP connection timeout and improve the initial metadata fetch
Enforce broker-wide and per-listener connection creation rate (KIP-612, part 1)
Throttle Create Topic, Create Partition and Delete Topic Operations
Add TRACE-level end-to-end latency metrics to Streams
Add Broker-side SCRAM Config API
Support PEM format for SSL certificates and private key
Add RocksDB Memory Consumption to RocksDB Metrics
Add Sliding-Window support for Aggregations

更多介绍请移步：https://downloads.apache.org/kafka/2.7.0/RELEASE_NOTES.html

标签: none

添加新评论