kafka2.7的代码改动

  • Post author:
  • Post category:其他


最近看了下kafka2.7.0的源码,相对2.0.0已经有挺多细节发生了变动。印象最深有两点:

  1. 日志索引项的二分查找做了优化。原理不复杂,但是却挺高级。问题是原版的二分查找是没有考虑到缓存的,一旦生成了新的索引项会强行变更查找路径。新版的算法考虑到了热区和冷区。
  2. Rebalance的时候,添加了静态consumer,就不必所有consumer全部参与重分配了,这也是在性能上有很大提升。

kafka2.0.0二分源码如下:

kafka-2.7.0二分源码如下:



版权声明:本文为fenglei0415原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。