Zookeeper實踐之：經過Zookeeper實現一個消費者進程分配程序

背景 須要實現一個分佈式監控程序，Agent把監控消息發送到Kafka,由消費者進程使用High Level API從Kafka獲取消息java 需求 隨着Agent數量的增長，每秒產生的消息數量也在增長，考慮到High Level的API使消費者進程與分區的固定關係，因此須要使用Zookeeper來維護一個消費者的集羣，使消費者能夠根據Kafka分區的數量以及消費者集羣的個數，動態的分配每一個消

>>阅读原文<<