apache-kafka - 如何从 kafka 连接日志文件中检查谁是活动控制器(代理 id)
问题描述
需要从任何日志文件(控制中心或 Kafka 连接日志文件等)中检查活动控制器是什么。实际上,我们有多个代理,其中一个是活动控制器(例如代理 01),现在它更改为代理 02(能够从控制中心 ui 中看到)。
所以我们只想知道它从Broker 01到Broker 02的确切更改时间(确切时间)。请帮我看看我们可以从日志文件或任何其他来源中找到它的确切位置。
解决方案
您是否重新启动了您的 broker01 实例?控制器正在移动,当当前控制器关闭另一个活动代理时,它的正常行为被选择为控制器,为了避免控制器移动两次,推荐的 kafka 集群滚动重启方式是重启控制器作为最后一个代理在集群中重新启动
通过命令 cli,您可以从 zookeeper 命令外壳检查活动控制器
./bin/zookeeper-shell.sh [ZK_IP] 获取 /controller
您可以检查代理的 controller.log 通常当代理开始写入 controller.log 时,它被选为控制器的时间,其他代理此时不会写入 controller.log 文件 -</p>
可能是您的 controller.log 包含上一次它是控制器的数据,在您的其他集群 controller.log 中应该有 DEBUG 消息,如果启用状态“代理 x 已被选为控制器”
推荐阅读
- r - 检查一个日期列是否存在于另一个日期列中
- python - 使用 :raises: 来自可能由当前方法中的方法引起的异常的文档字符串
- postgresql - 如何在 Postgresql 中使用 case when 创建数据透视表?
- .htaccess - htaccess 拒绝通过正则表达式访问 URI
- dataweave - 基于 DateTime Dataweave 过滤负载
- javascript - JavaScript 中 Promise 的 Python 等价物是什么?
- algorithm - 为什么桶排序被认为是非比较排序?
- reactjs - 禁用提升时,如何将 React 库从一个 Yarn 工作区导入另一个工作区?
- python - 提取游戏数据:不正确的值
- matplotlib - 图形格式 - X 轴表示法和注释 - Matplotlib