golang 获取集群中kafka的角色

要获取 Kafka 集群中每个节点的角色，你可以使用 Kafka 的管理工具（如 Apache Kafka AdminClient）来实现。下面是一个使用 Golang 获取 Kafka 集群节点角色的示例代码：

package main

import (
	"fmt"
	"github.com/Shopify/sarama"
)

func main() {
	// Kafka 集群的地址和端口
	brokers := []string{"localhost:9092"}

	// 创建 Kafka AdminClient
	config := sarama.NewConfig()
	admin, err := sarama.NewClusterAdmin(brokers, config)
	if err != nil {
		fmt.Println("创建 Kafka AdminClient 失败:", err)
		return
	}
	defer admin.Close()

	// 获取集群中所有节点的信息
	nodes, err := admin.DescribeCluster()
	if err != nil {
		fmt.Println("获取集群信息失败:", err)
		return
	}

	// 打印节点角色信息
	for _, node := range nodes.Nodes {
		fmt.Printf("节点 ID: %d, 角色: %s\n", node.ID, node.Rack)
	}
}

在上面的代码中，我们使用 `sarama` 库创建了一个 Kafka 的 `ClusterAdmin` 客户端，并调用 `DescribeCluster` 方法获取集群中所有节点的信息。然后我们遍历每个节点，打印节点的 ID 和角色信息。

请注意，你需要先安装 `sarama` 库，你可以使用以下命令进行安装：

go get github.com/Shopify/sarama

另外，代码中的 `brokers` 变量需要根据你的实际情况进行修改，以匹配你的 Kafka 集群的配置。

希望这个示例能帮助你获取 Kafka 集群中每个节点的角色信息。如果有任何疑问，请随时提问。