揭秘Kafka的高机能吞吐

Consumer端的计划概略上还算是较量通例的。

• 通过Consumer Group，可以支持出产者斲丧者和行列会见两种模式。
• Consumer API分为High level和Low level两种。前一种重度依靠Zookeeper，以是机能差一些且不自由，可是超省心。第二种不依靠Zookeeper处事，无论从自由度和机能上都有更好的示意，可是全部的非常(Leader迁徙、Offset越界、Broker宕机等)和Offset的维护都必要自行处理赏罚。
• 各人可以存眷下不日宣布的0.9 Release。开拓职员又用Java重写了一套Consumer。把两套API归并在一路，同时去掉了对Zookeeper的依靠。听说机能有大幅度晋升哦~~

Tips

凶猛保举行使Low level API，固然繁琐一些，可是今朝只有这个API可以对Error数据举办自界说处理赏罚，尤其是处理赏罚Broker非常或因为Unclean Shutdown导致的Corrupted Data时，不然无法Skip只能等着“坏动静”在Broker上被Rotate掉，在此时代该Replica将会一向处于不行用状态。

（编辑：河北网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!