Kafka全面进入2.x时代

Posted 2021-05-02 朱小厮的博客

技术文章第一时间送达！

Kafka秉承着每4个月发布一个版本的速度，距离上次发布2.0.0版本已将近4个月之久，今日笔者发现Kafka官网的版本已经如期变更为2.1.0，这也标识着Kafka已经全面进入了2.x时代，如果你还在用着1.x版本的kafka，甚至是0.8、0.10之类版本的Kafka的话，不妨踊跃的来尝尝鲜吧。

相比与2.0.0而言，2.1.0的变更很少，Kafka官网的变更记录如下：
Notable changes in 2.1.0

• Jetty has been upgraded to 9.4.12, which excludes TLS_RSA_* ciphers by default because they do not support forward secrecy, see https://github.com/eclipse/jetty.project/issues/2807 for more information.

• Unclean leader election is automatically enabled by the controller when unclean.leader.election.enable config is dynamically updated by using per-topic config override.

• The AdminClient has added a method AdminClient#metrics(). Now any application using the AdminClient can gain more information and insight by viewing the metrics captured from the AdminClient. For more information see KIP-324

• Kafka now supports Zstandard compression from KIP-110. You must upgrade the broker as well as clients to make use of it. Consumers prior to 2.1.0 will not be able to read from topics which use Zstandard compression, so you should not enable it for a topic until all downstream consumers are upgraded. See the KIP for more detail.

2.1.0变更少，也从侧面反映了之前的Kafka 2.0.0足够优秀。Kafka 2.0.0版本相比于之前就变更了很多（具体的可以参考http://kafka.apache.org/documentation/#upgrade_200_notable），比如不在支持JDK7，旧版的Scala客户端被删除，与主题__consumer_offsets相关的offsets.retention.minutes的默认值从1天变成了7天，这些都是很有意义的改动。笔者从Kafka 2.0.0版本发布开始，就翻过全部的源码，之前的十几篇关于Kafka的文章（查看“阅读原文”链接）也都是基于Kafka 2.0.0版本写的，通过与之前的Kafka 1.x的源码相比，发现其中的细枝末节的优化改动非常之多，相信你们在升级完Kafka之后也能够感受得到。

还在等什么，有条件的赶紧升级吧。

---

往

期

精

彩

《》

《》

《》

《》

>>><