1package kafkademo
2
3import (
4	"fmt"
5	"log"
6
7	"github.com/baidubce/bce-sdk-go/bce"
8	"github.com/baidubce/bce-sdk-go/services/kafka"
9)
10
11func getClusterWithErrorHandling() {
12	client := newKafkaClient()
13
14	request := &kafka.GetClusterDetailRequest{
15		ClusterID: "{{集群 ID}}",
16	}
17
18	response, err := client.GetClusterDetail(request)
19	if err != nil {
20		switch typed := err.(type) {
21		case *bce.BceServiceError:
22			// 服务端返回错误
23			log.Printf("code=%s status=%d requestId=%s message=%s",
24				typed.Code, typed.StatusCode, typed.RequestId, typed.Message)
25		case *bce.BceClientError:
26			// 网络或客户端错误
27			log.Printf("client error: %s", typed.Message)
28		default:
29			// 参数校验失败，请求未发出，不需要重试
30			log.Printf("invalid request: %v", err)
31		}
32		return
33	}
34
35	if response.Cluster != nil {
36		fmt.Printf("state=%s
37", response.Cluster.State)
38	}
39}