private ClientBroker.RegisterRequestC2B createBrokerRegisterRequest(Partition partition) {
        ClientBroker.RegisterRequestC2B.Builder builder =
                ClientBroker.RegisterRequestC2B.newBuilder();
        builder.setClientId(consumerId);
        builder.setGroupName(this.consumerConfig.getConsumerGroup());
        builder.setOpType(RpcConstants.MSG_OPTYPE_REGISTER);
        builder.setTopicName(partition.getTopic());
        builder.setPartitionId(partition.getPartitionId());
        builder.setQryPriorityId(rmtDataCache.getQryPriorityId());
        builder.setReadStatus(getGroupInitReadStatus(rmtDataCache.bookPartition(partition.getPartitionKey())));
        TopicProcessor topicProcessor =
                this.consumeSubInfo.getTopicProcessor(partition.getTopic());
        if (topicProcessor != null && topicProcessor.getFilterConds() != null) {
            builder.addAllFilterCondStr(topicProcessor.getFilterConds());
        }
        if (this.isFirst.get()
                && consumeSubInfo.isRequireBound()
                && consumeSubInfo.getIsNotAllocated()) {
            Long currOffset = consumeSubInfo.getAssignedPartOffset(partition.getPartitionKey());
            if (currOffset != null && currOffset >= 0) {
                builder.setCurrOffset(currOffset);
            }
        }
        builder.setAuthInfo(genBrokerAuthenticInfo(partition.getBrokerId(), false));
        return builder.build();
    }
Unregister partitions.

@param unRegisterInfoMap partitions to be unregister
inlong-tubemq/tubemq-client/src/main/java/org/apache/inlong/tubemq/client/consumer/BaseMessageConsumer.java