1package com.example.kafka;
2
3import com.baidubce.Protocol;
4import com.baidubce.auth.DefaultBceCredentials;
5import com.baidubce.services.kafka.KafkaClient;
6import com.baidubce.services.kafka.KafkaClientConfiguration;
7import com.baidubce.services.kafka.model.cluster.Cluster;
8import com.baidubce.services.kafka.model.cluster.ListClustersRequest;
9import com.baidubce.services.kafka.model.cluster.ListClustersResponse;
10
11public class QuickStart {
12
13    public static void main(String[] args) {
14        KafkaClientConfiguration config = new KafkaClientConfiguration();
15        config.setCredentials(new DefaultBceCredentials(
16                System.getenv("BCE_ACCESS_KEY_ID"),
17                System.getenv("BCE_SECRET_ACCESS_KEY")));
18        config.setEndpoint(System.getenv("KAFKA_ENDPOINT"));
19        config.setProtocol(Protocol.HTTPS);
20
21        KafkaClient client = new KafkaClient(config);
22        try {
23            ListClustersRequest request = new ListClustersRequest();
24            request.setMaxKeys(100);
25
26            ListClustersResponse response = client.listClusters(request);
27            for (Cluster cluster : response.getClusters()) {
28                System.out.printf("clusterId=%s name=%s state=%s%n",
29                        cluster.getClusterId(), cluster.getName(), cluster.getState());
30            }
31        } finally {
32            client.shutdown();
33        }
34    }
35}

1export BCE_ACCESS_KEY_ID="{{Access Key ID}}"
2export BCE_SECRET_ACCESS_KEY="{{Secret Access Key}}"
3export KAFKA_ENDPOINT="{{Kafka Endpoint}}"
4
5mvn -q compile exec:java -Dexec.mainClass=com.example.kafka.QuickStart

1clusterId={{集群ID}} name={{集群名称}} state={{集群状态}}