如何用java检查Kafka中的生产者id，客户id？

import org.apache.kafka.clients.admin.AdminClient;
import org.apache.kafka.clients.admin.AdminClientConfig;
import org.apache.kafka.clients.admin.ConsumerGroupListing;
import org.apache.kafka.clients.admin.DescribeConsumerGroupsOptions;
import org.apache.kafka.clients.admin.DescribeConsumerGroupsResult;
import org.apache.kafka.clients.admin.ListConsumerGroupsResult;
import org.apache.kafka.clients.consumer.OffsetAndMetadata;
import org.apache.kafka.clients.consumer.OffsetResetStrategy;
import org.apache.kafka.common.TopicPartition;
import org.apache.kafka.common.serialization.StringDeserializer;

import java.util.*;

public class KafkaClientIdChecker {

    public static void main(String[] args) {
        // Kafka服务器配置
        Properties props = new Properties();
        props.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, "kafka_server:9092");

        // 创建AdminClient
        try (AdminClient adminClient = AdminClient.create(props)) {
            // 获取消费者组列表
            ListConsumerGroupsResult consumerGroupsResult = adminClient.listConsumerGroups();
            Set<String> consumerGroupIds = new HashSet<>();
            for (ConsumerGroupListing consumerGroupListing : consumerGroupsResult.all().get()) {
                consumerGroupIds.add(consumerGroupListing.groupId());
            }

            // 描述消费者组
            DescribeConsumerGroupsOptions describeOptions = new DescribeConsumerGroupsOptions()
                    .timeoutMs(5000); // 设置描述消费者组的超时时间
            DescribeConsumerGroupsResult describeResult = adminClient.describeConsumerGroups(consumerGroupIds, describeOptions);
            Map<String, OffsetAndMetadata> groupOffsets = new HashMap<>();

            // 遍历消费者组，获取偏移量和客户端ID
            for (String groupId : consumerGroupIds) {
                groupOffsets.putAll(describeResult.describedGroups().get(groupId).offsets());
            }

            // 打印生产者ID和客户端ID
            for (Map.Entry<String, OffsetAndMetadata> entry : groupOffsets.entrySet()) {
                String clientId = entry.getKey();
                OffsetAndMetadata offsetAndMetadata = entry.getValue();
                System.out.println("生产者ID: " + clientId);
                System.out.println("客户端ID: " + offsetAndMetadata.metadata());
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}