首页 > 解决方案 > 如何从 kafka 连接日志文件中检查谁是活动控制器(代理 id)

问题描述

需要从任何日志文件(控制中心或 Kafka 连接日志文件等)中检查活动控制器是什么。实际上,我们有多个代理,其中一个是活动控制器(例如代理 01),现在它更改为代理 02(能够从控制中心 ui 中看到)。

所以我们只想知道它从Broker 01到Broker 02的确切更改时间(确切时间)。请帮我看看我们可以从日志文件或任何其他来源中找到它的确切位置。

标签: apache-kafkaapache-kafka-connectconfluent-control-center

解决方案


您是否重新启动了您的 broker01 实例?控制器正在移动,当当前控制器关闭另一个活动代理时,它的正常行为被选择为控制器,为了避免控制器移动两次,推荐的 kafka 集群滚动重启方式是重启控制器作为最后一个代理在集群中重新启动

通过命令 cli,您可以从 zookeeper 命令外壳检查活动控制器

./bin/zookeeper-shell.sh [ZK_IP] 获取 /controller

您可以检查代理的 controller.log 通常当代理开始写入 controller.log 时,它被选为控制器的时间,其他代理此时不会写入 controller.log 文件 -</p>

可能是您的 controller.log 包含上一次它是控制器的数据,在您的其他集群 controller.log 中应该有 DEBUG 消息,如果启用状态“代理 x 已被选为控制器”


推荐阅读