---

前言

前面两节，我们已经简单应用了sarama的两个类型Client和ClusterAdmin，其中有一个案例是获取集群的ControllerId，但是在后面的测试过程过程中，发现一个问题，返回的ControllerID是随机的，这个是什么原因呢，我们下面分析下

---

一、先上结果

下图展示了我用四种方式，获取到的ControllerId的信息，分别是
ClusterAdmin 的 DescribeCluster()
ClusterAdmin 的 Controller()
Client的 Controller()
Clinet的 RefreshController()
可以看到每次返回的四个结果都不一致

开始我也怀疑是不是我的kafka集群本身有问题，但是通过kafka工具查看

./bin/kafka-metadata-quorum.sh --bootstrap-server 172.20.37.227:34997  descr
ibe  --status

集群的Controller的LeaderID尽管在更新，但是不会短时间内迅速切换，所以集群没有问题。

二、刨根问底

ControllerID返回结果随机是什么原因呢，一顿查找，终于是找的一个类似的问题。

传送门：
DescribeCluster() returns random broker ID as the controller ID under KRaft mode #2521

这个开发者也是遇到和我一样的困惑，为什么获取到的ControllerID和kafka-metadata-quorum.sh获取的不一致呢。

解答在这里：

kafka 在kraft模式是希望您将请求发送到集群中的任何节点，并且它会相应地进行负载平衡

目前我们用的sarama v1.42.2版本还是有这个问题的，但是作者，提示会在后期更新类似的方法，获得我们需要的结果。

总结

sarama本身也是遵循了kafka kraft版本的代码行为，就使用来说，对客户端是无所谓的，有人相应就好，但是作为运维和排查问题角度，还是需要一个方法，获取到目前集群的Controler的Leader具体是哪个节点。我们可以继续关注这个问题。