1package main
2
3import (
4	"fmt"
5	"log"
6	"os"
7
8	"github.com/baidubce/bce-sdk-go/services/kafka"
9)
10
11func main() {
12	client, err := kafka.NewClient(
13		os.Getenv("BCE_ACCESS_KEY_ID"),
14		os.Getenv("BCE_SECRET_ACCESS_KEY"),
15		os.Getenv("KAFKA_ENDPOINT"),
16	)
17	if err != nil {
18		log.Fatalf("failed to create kafka client: %v", err)
19	}
20
21	request := &kafka.ListClustersRequest{
22		ListRequest: kafka.ListRequest{MaxKeys: 100},
23	}
24
25	response, err := client.ListClusters(request)
26	if err != nil {
27		log.Fatalf("failed to list clusters: %v", err)
28	}
29
30	for _, cluster := range response.Clusters {
31		fmt.Printf("clusterId=%s name=%s state=%s
32",
33			cluster.ClusterID, cluster.Name, cluster.State)
34	}
35}

1export BCE_ACCESS_KEY_ID="{{Access Key ID}}"
2export BCE_SECRET_ACCESS_KEY="{{Secret Access Key}}"
3export KAFKA_ENDPOINT="{{Kafka Endpoint}}"
4
5go run main.go

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