版本Sarama - v1.32.0Kafka - 5.4.6-2.12Go - v1.16.2sarama.Logger = log.New(os.Stderr, "[Sarama] ", log.LstdFlags)brokers := []string{    "kafka1:9092",    "kafka2:9092",}cfg := sarama.NewConfig()cfg.Version = sarama.V2_4_0_0admin, err := sarama.NewClusterAdmin(brokers, sarama.NewConfig())if err != nil {    log.Fatal(err)}brok, _, err := admin.DescribeCluster()if err != nil {    log.Fatal(err)}for _, b := range brok {    chck, err := b.Connected()    if err != nil {        log.Fatal(err)    }    log.Println(chck)}我正在嘗試檢查代理是否已連接，但它為方法 Connected() 返回 false。如果有關于為什么它返回 false 的解釋？我需要寫一份健康檢查，所以我最初的計劃是檢查經紀人是否已連接，但我可以做其他檢查嗎？saramaConfig := sarama.NewConfig()saramaConfig.Version = sarama.V2_0_0_0client, err := sarama.NewClient(brokers, saramaConfig)if err != nil {    log.Fatal("NewKafkaAdmin", fmt.Sprintf(`cannot get controller - %+v`, err))}b, _ := client.Controller()fmt.Println(b.Connected())這返回真。為什么會有這樣的不匹配？