Sarama集群管理-代理连接方法返回false

Question

版本

萨拉马- v1.32.0

Kafka - 5.4.6-2.12

Go - v1.16.2

sarama.Logger = log.New(os.Stderr, "[Sarama] ", log.LstdFlags)
brokers := []string{
    "kafka1:9092",
    "kafka2:9092",
}

cfg := sarama.NewConfig()
cfg.Version = sarama.V2_4_0_0
admin, 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)
}

我正在尝试检查代理是否已连接，但它返回连接()方法的false。如果有关于为什么返回false的解释？我需要写一份健康检查，所以我的最初计划是检查经纪人是否有关联，但我还能做其他的检查吗？

saramaConfig := sarama.NewConfig()
saramaConfig.Version = sarama.V2_0_0_0

client, 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())

这个回归是真的。为何会有这种错配呢？

Answer 1

这不能使用DescribeCluster方法完成。详细解释可在以下问题中找到。

https://github.com/Shopify/sarama/issues/2222