public Long getConsumerRegisterTime(String consumerId, String partitionStr) {
        TimeoutInfo timeoutInfo =
                heartbeatManager.getConsumerRegMap()
                        .get(getHeartbeatNodeId(consumerId, partitionStr));
        if (timeoutInfo == null) {
            return null;
        }
        return (timeoutInfo.getTimeoutTime() - heartbeatManager.getConsumerTimeoutDlt());
    }
Get consumer's register time.

@param consumerId
@param partitionStr
@return
inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/BrokerServiceServer.java