apache-kafka - Kafka - 控制器代理
问题描述
我从https://niqdev.github.io/devops/kafka/ 和https://livebook.manning.com/book/kafka-streams-in-action/chapter-2/109(Kafka Streams in行动 )
控制器代理负责为主题的所有分区建立领导者/追随者关系。如果 Kafka 节点死亡或无响应(对 ZooKeeper 心跳),则控制器代理重新分配其分配的所有分区(领导者和跟随者) 。
我认为将追随者分区分配给其他经纪人是不正确的——因为除非经纪人回来,否则这些分区不会自行修复。我知道这只发生在领导者副本上,如果领导者副本的代理出现故障,则包含追随者的代理之一将成为领导者。但是,我不认为追随者的“重新分配”会自动发生,除非手动启动重新分配。请添加您的输入
解决方案
该术语可能确实有点偏离,但仍然适用。追随者不一定分配给其他代理,但他们需要将端点更改为他们将发送获取请求的位置。The follower's job is to stay in-sync with the leader, and if the leader has been assigned to a new broker because the old one failed then the followers need to send their fetch requests to the new elected broker. 我认为这就是在您分享的上下文中重新分配的含义。
推荐阅读
- c# - 使用 HttpClient 将 ajax POST 转换为 .net
- tcl - 通信两个 IVR 应用程序
- python - ImportError:从 C++ 运行 python 文件时无法在 Visual Studio 调试控制台中导入名称“etree”
- javascript - 由于 .classList.toggle,按钮的行为很奇怪
- javascript - 持续检测鼠标移动 JavaScript
- azure-data-lake - Azure Synapse Serverless - SQL 查询为每个文件返回目录中的行
- tfs - TFS 代码审查自动设置了 Closed By 字段,这阻止我访问代码审查
- excel-formula - 提取以 " 引号开头的单词
- intellij-idea - IDEA 无法识别 typegoose 类型的模型
- python - Python Altair - 条形图 - 比例绑定