如何从kafka连接日志文件中检查谁是活动控制器(代理id)



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

所以我们只想知道它从Broker 01更改为Broker 02的确切时间。请帮助我,当它被更改时,我们可以从日志文件或任何其他来源找到它。

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

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

/bin/zookeeper-shell.sh[ZK_IP]获取/控制器

您可以查看经纪人的controller.log通常,当代理程序在被选为控制器时开始写入controller.log时,其他代理程序此时不会写入controller.log文件–

它可能是您的控制器。日志包含上次作为控制器时的数据,在您的另一个集群控制器中。日志中应该有DEBUG消息,如果启用状态为";经纪人x已被选为控制者";

最新更新