消息总量

kafka监控获取指定topic的消息总量示例

我就废话不多说了，直接 上代码吧！ import kafka.api.PartitionOffsetRequestInfo; import kafka.common.TopicAndPartiti