Можно ли узнать потребляемое смещение данной группы потребителей Kafka через java-программу?

Можно ли узнать потребляемое смещение данной группы потребителей через программу Java. Конечно, мы можем узнать об этом, используя приведенную ниже команду группы потребителей.

bin/kafka-run-class.sh kafka.admin.ConsumerGroupCommand --describe --group kafka-grp --bootstrap-server localhost:9092


java apache-kafka
person Yarra    schedule 25.08.2018    source источник
comment
Возможный дубликат Как я могу получить ПОСЛЕДНЕЕ смещение темы кафки?   -  person Emre Savcı    schedule 25.08.2018
comment
kafka.admin.ConsumerGroupCommand — это класс Java, который вы можете импортировать и использовать в своем собственном коде.   -  person OneCricketeer    schedule 25.08.2018
comment
В частности, вы можете скопировать большую часть кода из этого класса github.com/apache/kafka/blob/trunk/core/src/main/scala/kafka/   -  person OneCricketeer    schedule 25.08.2018