如何获取kafka的logSize,offSize,lag呢

项目中的kafka需要做监控，以及topic的的写入消费数offsize，未消费数log，找遍了各种资料，没有找到获取offsize的途径，这样放才能获取topic未消费量。

kafka版本2.11-1.1.0，望大佬抽出宝贵的时间指点一二，最好能有代码。