接到领导的一个需求，希望封装一下kafka的消费者，可以从配置读取topic进行消费；一开始首先想到的是用java kafka的高阶api手工根据topic创建消费者，一个topic创建一个消费者，依赖zookeeper完成kafka内部的balance和其他管理。后来领导又提出不要依赖zookeeper，之前老是rebalance失败。       调研了一下，手工实现类似sp..