使用java 实现指定消费组和主题查看消费情况

要使用Java实现指定消费组和主题查看消费情况，可以使用Apache Kafka提供的Java客户端API。以下是一个简单的示例代码：

import java.util.Properties;
import org.apache.kafka.clients.consumer.ConsumerConfig;
import org.apache.kafka.clients.consumer.KafkaConsumer;
import org.apache.kafka.common.TopicPartition;
import org.apache.kafka.common.serialization.StringDeserializer;

public class ConsumerExample {
  public static void main(String[] args) {
    // 配置消费者客户端
    Properties props = new Properties();
    props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
    props.put(ConsumerConfig.GROUP_ID_CONFIG, "my-group");
    props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName());
    props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName());
    
    // 创建消费者客户端
    KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);

    // 订阅指定主题
    consumer.subscribe(Arrays.asList("my-topic"));

    // 获取分区列表
    List<TopicPartition> partitions = new ArrayList<>();
    for (TopicPartition partition : consumer.assignment()) {
      if (partition.topic().equals("my-topic")) {
        partitions.add(partition);
      }
    }

    // 获取消费情况
    Map<TopicPartition, Long> offsets = consumer.endOffsets(partitions);

    // 输出消费情况
    for (Map.Entry<TopicPartition, Long> entry : offsets.entrySet()) {
      System.out.printf("Partition %s: offset %d\n", entry.getKey().partition(), entry.getValue());
    }

    // 关闭消费者客户端
    consumer.close();
  }
}

在上面的示例代码中，我们首先配置了消费者客户端，然后创建了一个KafkaConsumer实例，并订阅了指定的主题。接下来，我们获取订阅的分区列表，并通过KafkaConsumer的endOffsets()方法获取了消费情况。最后，我们输出了每个分区的消费情况，并关闭了消费者客户端。

需要注意的是，以上示例代码仅仅是演示了如何获取指定消费组和主题的消费情况，实际使用时还需要处理异常、设置超时时间等。