private void freezeOrUnFreezeParts(List<String> partitionKeys,
            boolean isFreeze) throws TubeClientException {
        if (partitionKeys == null || partitionKeys.isEmpty()) {
            return;
        }
        StringBuilder sBuilder = new StringBuilder(256);
        List<String> validPartKeys = new ArrayList<String>();
        for (String partKey : partitionKeys) {
            String tmpKey = validPartitionKey(sBuilder, partKey);
            validPartKeys.add(tmpKey);
        }
        this.rmtDataCache.freezeOrUnFreezeParts(validPartKeys, isFreeze);
    }
Get partition information of the consumer.

@return consumer partition information
inlong-tubemq/tubemq-client/src/main/java/org/apache/inlong/tubemq/client/consumer/BaseMessageConsumer.java