private ClientMaster.HeartRequestC2M createMasterHeartbeatRequest(ConsumerEvent event,
            List<SubscribeInfo> subInfoList,
            boolean reportSubscribeInfo) throws Exception {
        ClientMaster.HeartRequestC2M.Builder builder = ClientMaster.HeartRequestC2M.newBuilder();
        builder.setClientId(this.consumerId);
        builder.setGroupName(this.consumerConfig.getConsumerGroup());
        builder.setReportSubscribeInfo(reportSubscribeInfo);
        builder.setDefFlowCheckId(rmtDataCache.getDefFlowCtrlId());
        builder.setQryPriorityId(rmtDataCache.getQryPriorityId());
        builder.setGroupFlowCheckId(rmtDataCache.getGroupFlowCtrlId());
        if (event != null) {
            ClientMaster.EventProto.Builder eventProtoBuilder =
                    ClientMaster.EventProto.newBuilder();
            eventProtoBuilder.setRebalanceId(event.getRebalanceId());
            eventProtoBuilder.setOpType(event.getType().getValue());
            eventProtoBuilder.setStatus(event.getStatus().getValue());
            eventProtoBuilder.addAllSubscribeInfo(
                    DataConverterUtil.formatSubInfo(event.getSubscribeInfoList()));
            ClientMaster.EventProto eventProto = eventProtoBuilder.build();
            builder.setEvent(eventProto);
        }
        if (subInfoList != null) {
            builder.addAllSubscribeInfo(DataConverterUtil.formatSubInfo(subInfoList));
        }
        ClientMaster.MasterCertificateInfo authInfo = genMasterCertificateInfo(false);
        if (authInfo != null) {
            builder.setAuthInfo(authInfo);
        }
        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