【问题标题】:What happens in Sarama library when a consumer tries to connect to a down broker?当消费者尝试连接到停机代理时,Sarama 库中会发生什么?
【发布时间】:2019-12-12 00:33:31
【问题描述】:

当消费者尝试连接到故障代理时,Sarama 库中会发生什么?它会返回错误吗?

【问题讨论】:

    标签: go apache-kafka sarama


    【解决方案1】:

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

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

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

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 2018-01-15
      • 2017-07-11
      • 2017-12-18
      • 2020-07-19
      • 1970-01-01
      • 2017-06-10
      • 2017-12-14
      • 2021-02-05
      相关资源
      最近更新 更多