消息队列一直是一个神兵利器，我之前也写过用于简化kafka消费和生产的中间件，其完整版也尝试在一些项目中使用。效果也还不错，这里也是巧然了解到可以增加Kafka单一partition并发消费能力的方法（为了保证partition而使用单一线程进行消费），也找到了解决方法，这里是对代码的一些分析，完整的注释解析就不放了。

Databus学习

分片和链表的两者结合，分片可提高并发能力的同时，按链表顺序逐个回收数据，又能保证对不同shard的统一partition顺序保证，这样的设计还是非常巧妙的。