谢谢你的建议。因为我们正在寻找zookeeper中存储的偏移量,所以需要使用 bin/kafka-consumer-groups.sh--zookeeper--descripe--group
相应的scala api在
ConsumerGroupCommand.scala