1package com.example.kafka;
2
3import com.baidubce.BceClientException;
4import com.baidubce.BceServiceException;
5import com.baidubce.services.kafka.KafkaClient;
6import com.baidubce.services.kafka.model.cluster.GetClusterDetailRequest;
7import com.baidubce.services.kafka.model.cluster.GetClusterDetailResponse;
8
9public class ErrorHandlingDemo {
10
11    public static void main(String[] args) {
12        KafkaClient client = KafkaClientFactory.create();
13        try {
14            GetClusterDetailRequest request = new GetClusterDetailRequest();
15            request.setClusterId("{{集群 ID}}");
16
17            GetClusterDetailResponse response = client.getClusterDetail(request);
18            System.out.println("requestId=" + response.getMetadata().getBceRequestId());
19            System.out.println("state=" + response.getCluster().getState());
20        } catch (IllegalArgumentException e) {
21            // 参数校验失败，请求未发出，不需要重试
22            System.err.println("invalid request: " + e.getMessage());
23        } catch (BceServiceException e) {
24            // 服务端返回错误
25            System.err.printf("code=%s status=%d requestId=%s message=%s%n",
26                    e.getErrorCode(), e.getStatusCode(),
27                    e.getRequestId(), e.getErrorMessage());
28        } catch (BceClientException e) {
29            // 网络或客户端错误
30            System.err.println("client error: " + e.getMessage());
31        } finally {
32            client.shutdown();
33        }
34    }
35}

1String requestId = response.getMetadata().getBceRequestId();