相关疑难解决方法(0)

我写了一个java程序来消耗来自kafka的消息.我想监视消耗滞后,如何通过java获取它？

顺便说一句,我使用:

<groupId>org.apache.kafka</groupId>
<artifactId>kafka_2.11</artifactId>
<version>0.10.1.1</version>

提前致谢.