我用 ConsumerGroupCommand.main(new String[]{"--bootstrap-server", bootstrapServers, "--group", groups, "--describe"}); 监视 lag 的 kafka ，但我发现代码很慢，有时需要几分钟？
我的 kafka 集群有3个代理，每个代理 topic 有 50 分区。