通过JMX在Java应用程序中程序化获取统计信息

import javax.management.MBeanServer;
import java.lang.management.ManagementFactory;

public class JMXExample {
    public static void main(String[] args) {
        MBeanServer mbs = ManagementFactory.getPlatformMBeanServer();

        // 现在你可以使用mbs来查询和访问MBean了
    }
}

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.ApplicationContext;
import javax.management.MBeanServer;

@SpringBootApplication
public class JMXSpringBootExample {

    @Autowired
    private MBeanServer mbs;

    public static void main(String[] args) {
        ApplicationContext context = SpringApplication.run(JMXSpringBootExample.class, args);
        JMXSpringBootExample example = context.getBean(JMXSpringBootExample.class);
        // 现在你可以使用example.mbs来查询和访问MBean了
        example.accessJMXData();
    }

    public void accessJMXData() {
        // 使用mbs进行JMX操作
    }
}

import javax.management.*;
import java.util.Set;

public class KafkaLagExample {

    public static void main(String[] args) throws MalformedObjectNameException, NullPointerException, InstanceNotFoundException, MBeanException, ReflectionException {
        MBeanServer mbs = ManagementFactory.getPlatformMBeanServer();
        ObjectName objectName = new ObjectName("kafka.consumer:type=consumer-fetch-manager-metrics,client-id=your-client-id,topic=your-topic,partition=your-partition");

        // 查询所有匹配的MBean
        Set<ObjectInstance> beans = mbs.queryMBeans(objectName, null);

        for (ObjectInstance bean : beans) {
            // 获取Lag属性的值
            Object lag = mbs.getAttribute(bean.getObjectName(), "records-lag-max"); // 假设Lag属性名为"records-lag-max"
            System.out.println("Lag: " + lag);
        }
    }
}