怎么在SASL认证期间知道Kafka客户端（生产者或消费者）的第一个代理端口？

在使用SASL认证时，Kafka客户端需要连接Kafka代理才能进行生产或消费。这就需要知道Kafka代理的地址和端口。可以使用Kafka的Java API中的AdminClient类来获取代理的网络地址和端口。

下面是一个示例代码，说明如何使用AdminClient类获取代理的第一个端口号。请注意，代码样例中使用了SASL_PLAINTEXT认证方式：

// 设置Kafka客户端的安全属性
Properties props = new Properties();
props.put("security.protocol", "SASL_PLAINTEXT");
props.put("sasl.mechanism", "PLAIN");
props.put("sasl.jaas.config", "org.apache.kafka.common.security.plain.PlainLoginModule required username=\"username\" password=\"password\";");
 
// 创建一个AdminClient实例
AdminClient adminClient = AdminClient.create(props);
 
// 获取代理的元数据信息
List<MetadataResponse.TopicMetadata> topicsMetadata = adminClient.describeTopics(Arrays.asList("my-topic")).all().get().values().stream()
    .map(kafkaFuture -> {
        try {
            return kafkaFuture.get();
        } catch (InterruptedException | ExecutionException e) {
            throw new RuntimeException(e);
        }
    }).collect(Collectors.toList());
 
// 获取代理的第一个端口号
int firstBrokerPort = Integer.parseInt(topicsMetadata.get(0).partitions().get(0).leader().host().split(":")[1]);

上述代码使用AdminClient获取了代理的元数据信息，并从中提取了第一个代理的端口号。可以根据需求进行修改，以获取其他信息。