当消费者尝试连接到故障的Broker时，Sarama库中会出现什么情况？

Sarama库中，当消费者尝试连接到故障的Broker时，如果主题的复制因子大于1且已选举新代理领导者，消费者将重新平衡到领导者分区。在Kafka 2.4版本中，客户端可从同步副本读取数据。但如果分区仅有一个可用代理且该代理已关闭，Sarama和所有相关客户端将抛出错误。

当消费者尝试连接到故障经纪人时，Sarama 库中会发生什么？它返回错误吗？

解决方案

如果这些主题的复制因子大于 1，并且为这些主题分区选举了新代理的领导者，那么消费者将重新平衡到领导者分区。

在 Kafka 2.4 版本中，客户端也将能够从同步副本中读取数据，而不仅仅是领导者代理，但是需要在 Sarama 的协议中添加该功能。

如果某个分区只有一个代理可用，并且该代理已关闭，那么 Sarama 和所有其他读取和写入该主题的客户端都会抛出错误，是的。

好了，本文到此结束，带大家了解了《当消费者尝试连接到故障的Broker时，Sarama库中会出现什么情况？》，希望本文对你有所帮助！关注golang学习网公众号，给大家分享更多Golang知识！