来！自己动手实现一个loghub(或kafka)分片消费负载均衡器

　　一般地，像kafka之类的消息中间件，作为一个可以保持历史消息的组件，其消费模型一般是主动拉取方式。这是为了给消费者足够的自由，回滚或者前进。 　　然而，也正是由于将消费消息的权力交给了消费者， ...