kafkaライブラリを使用して消費者オフセットの遅れを見つけるコードはありますか？

Question

私はカフカ消費者の進歩、すなわち遅れを得たいと思っています。私は次のコマンドが私に遅れや他の貴重な説明を与えることを知っています。

bin/kafka-run-class.sh kafka.admin.ConsumerGroupCommand --zookeeper localhost:2182 --describe --group DemoConsumer

bin/kafka-consumer-groups.sh --zookeeper localhost:2182 --describe --group DemoConsumer

私はまた、現在の消費者は、カフカ、クライアント

ConsumerRecords<Integer, String> records = consumer.poll(100); 
for (ConsumerRecord<Integer, String> record : records) { 

      System.out.println("Received message: (" + record.topic()+ ", 
      " + record.partition()+ ", " + record.key() + ", " + 
      record.value() + ") at offset " + record.offset()); 
} 

の助けを借りて、次のコードスニペットを使用してオフセットを得ることができますしかし、私は取得するためのコードを見つけることができません上記の2つのコマンドの詳細。カフカライブラリーを使って遅延やその他の詳細を見つけるためのコードはありますか？

Answer 1

this topicによれば、消費者の遅れを得ることができます。しかし、Mavenの依存性は、それが

<dependency> 
    <groupId>org.apache.kafka</groupId> 
    <artifactId>kafka_2.12</artifactId> 
    <version>0.10.2.0</version> 
</dependency> 

である必要があり、そのトピックで間違っていると、コードは次のとおりです。

AdminClient client = AdminClient.createSimplePlaintext("localhost:9092"); 
Map<TopicPartition, Object> offsets = JavaConversions.asJavaMap(
client.listGroupOffsets("groupID")); 
Long offset = (Long) offsets.get(new TopicPartition("topic", 0));