Kafka如何跟踪已注册的MBeans

Kafka使用JMX（Java Management Extensions）来管理和监控其各个组件。在Kafka中，各个组件（如broker、producer、consumer等）通过将其代理对象（proxy object）注册到指定的MBean服务器中来可见化自己。此后，外部监视器可以使用JMX连接到MBean服务器，并检查对象的状态、执行操作等。

Kafka使用KafkaMbean类作为代理对象，而MBean服务器缺省使用平台MBean服务器。KafkaMbean类实现org.apache.kafka.common.utils.MBeanRegistration接口，该接口的register和unregister方法用于注册/注销代理对象到MBean服务器中，代码示例如下：

public abstract class KafkaMbean implements MBeanRegistration {
    private ObjectName objectName; // MBean注册时的ObjectName

    @Override
    public ObjectName preRegister(MBeanServer server, ObjectName name) throws Exception {
        this.objectName = name;
        return this.objectName;
    }

    @Override
    public void postRegister(Boolean registrationDone) {
        // do nothing
    }

    @Override
    public void preDeregister() throws Exception {
        // do nothing
    }

    @Override
    public void postDeregister() {
        // do nothing
    }

    // 注册代理对象到MBean服务器中
    protected void register(String name, Object object) {
        try {
            MBeanServer mbeanServer = ManagementFactory.getPlatformMBeanServer();
            ObjectName objectName = this.objectName.append(name);
            mbeanServer.registerMBean(object, objectName);
        } catch (Exception e) {
            // handle exception
        }
    }

    // 注销代理对象到MBean服务器中
    protected void unregister(String name) {
        try {
            MBeanServer mbeanServer = ManagementFactory.getPlatformMBeanServer();
            ObjectName objectName = this.objectName.append(name);
            mbeanServer.unregisterMBean(objectName);
        } catch (Exception e) {
            // handle exception
        }
    }
}

在具体的Kafka组件中，一般继承上述KafkaMbean类，并实现其抽象方法和相关的MBean接口，如下面的BrokerTopicMetrics示例类所示：

public class BrokerTopicMetrics extends KafkaMbean implements BrokerTopicMetricsMBean {
    private final String brokerName;
    private final String topicName;
    private final AtomicInteger count;

    public BrokerTopicMetrics(String brokerName, String topicName) {
        this.b