kafka如何获取每一个消费者的积压数

我想通过程序来获取kafka的消费情况,目前的实现是根据topic的总偏移量来减去当前topic的所有消费者的偏移量之和,但是这样获取的未消费数是总的消费者之和,我应该如何获取某一个消费者的积压数呢,之前的代码是参考的github上的项目,或者这种kafka的client有相关的api吗,大佬们可以给个提示吗