为了监视kafka矩阵，我创建了一个监视工具，将值加载到javaapi中。
收集“bytesinpersec”和“bytesoutpersec”，计算差值以检查Kafka的状态。
顺便说一句，在监控Kafka时，经常会发现输出指标高于输入指标。价值的差别不小，而且差别很大。
你知道为什么会这样吗？