rocketMq获取多个消费组及消费组中brokerOffset和consumerOffset，同时不能指定topic 用java代码怎么实现脚本

要使用Java代码获取RocketMQ中多个消费组的brokerOffset和consumerOffset，同时不指定特定的topic，你可以使用RocketMQ的Java客户端来实现。下面是一个示例代码：

import org.apache.rocketmq.client.ClientConfig;
import org.apache.rocketmq.client.consumer.DefaultMQAdminExt;
import org.apache.rocketmq.client.exception.MQClientException;
import org.apache.rocketmq.common.admin.OffsetWrapper;
import org.apache.rocketmq.common.protocol.body.ConsumerConnection;
import org.apache.rocketmq.remoting.RPCHook;

import java.util.Map;
import java.util.Set;

public class RocketMQConsumerGroupOffset {
    public static void main(String[] args) {
        DefaultMQAdminExt adminExt = new DefaultMQAdminExt();
        adminExt.setInstanceName("admin");
        adminExt.setNamesrvAddr("127.0.0.1:9876");
        
        try {
            adminExt.start();
            
            // 获取所有消费组
            Set<String> consumerGroups = adminExt.fetchAllConsumerGroupNames();
            
            for (String consumerGroup : consumerGroups) {
                System.out.println("Consumer Group: " + consumerGroup);
                
                // 获取消费组内的消费者连接信息
                ConsumerConnection consumerConnection = adminExt.examineConsumerConnectionInfo(consumerGroup);
                String clientId = consumerConnection.getClientId();
                String clientAddr = consumerConnection.getClientAddr();
                
                System.out.println("Client ID: " + clientId);
                System.out.println("Client Address: " + clientAddr);
                
                // 获取消费组内每个消费者的brokerOffset和consumerOffset
                Map<String, OffsetWrapper> offsetTable = adminExt.fetchConsumerOffset(consumerGroup, null, false);
                
                for (Map.Entry<String, OffsetWrapper> entry : offsetTable.entrySet()) {
                    String topic = entry.getKey();
                    OffsetWrapper offsetWrapper = entry.getValue();
                    long brokerOffset = offsetWrapper.getBrokerOffset();
                    long consumerOffset = offsetWrapper.getConsumerOffset();
                    
                    System.out.println("Topic: " + topic);
                    System.out.println("Broker Offset: " + brokerOffset);
                    System.out.println("Consumer Offset: " + consumerOffset);
                }
                
                System.out.println("------------------------");
            }
        } catch (MQClientException e) {
            e.printStackTrace();
        } finally {
            adminExt.shutdown();
        }
    }
}

在上面的代码中，我们使用`DefaultMQAdminExt`类来连接RocketMQ的NameServer，并获取消费组、消费者连接信息以及brokerOffset和consumerOffset。你需要替换`setNamesrvAddr`方法的参数为你实际的NameServer地址。

请注意，上述代码仅适用于Apache RocketMQ 4.x版本。如果你使用的是较旧的版本，请查阅相应版本的RocketMQ文档以获取正确的API使用方法。