public boolean getSubscribablePartition(String partitionKey,
            ProcessResult result,
            StringBuilder sBuffer) {
        Tuple2<Partition, Integer> partStatusInfo =
                configuredPartInfoMap.get(partitionKey);
        if (partStatusInfo == null) {
            result.setFailResult(TErrCodeConstants.NOT_FOUND,
                    sBuffer.append("PartitionKey ").append(partitionKey)
                            .append(" not found in partition-meta Information set!")
                            .toString());
            sBuffer.delete(0, sBuffer.length());
            return result.isSuccess();
        }
        if (partStatusInfo.getF1() != 1) {
            result.setFailResult(TErrCodeConstants.PARTITION_UNSUBSCRIBABLE,
                    sBuffer.append("PartitionKey ").append(partitionKey)
                            .append(" not available for subscription now!")
                            .toString());
            sBuffer.delete(0, sBuffer.length());
            return result.isSuccess();
        }
        result.setSuccResult(partStatusInfo.getF0());
        return true;
    }
Get subscribable partition information

@param partitionKey   the partition key to query
@param result         the topic meta information
@param sBuffer        the string buffer
@return               whether query success
inlong-tubemq/tubemq-client/src/main/java/org/apache/inlong/tubemq/client/consumer/RmtDataCache.java