java获取kafkaconsumer的clientId

要获取KafkaConsumer的clientId，可以使用KafkaConsumer的client.id属性。这个属性可以在创建KafkaConsumer实例的时候设置，也可以在配置文件中设置。

以下是一个示例代码，演示如何获取KafkaConsumer的clientId：

import org.apache.kafka.clients.consumer.ConsumerConfig;
import org.apache.kafka.clients.consumer.KafkaConsumer;
import java.util.Properties;

public class ConsumerClientIdExample {
    public static void main(String[] args) {
        Properties props = new Properties();
        props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
        props.put(ConsumerConfig.GROUP_ID_CONFIG, "test-group");
        props.put(ConsumerConfig.CLIENT_ID_CONFIG, "test-client");
        props.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest");

        KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
        String clientId = consumer.clientId();
        System.out.println("KafkaConsumer client id: " + clientId);

        consumer.close();
    }
}

在上面的示例代码中，我们创建了一个KafkaConsumer实例，并设置了client.id属性为"test-client"。使用consumer.clientId()方法即可获取该KafkaConsumer实例的clientId。输出结果应该类似于："KafkaConsumer client id: test-client"。