private void unregisterPartition(Partition partition,
            boolean isLastConsumed, StringBuilder sBuffer) {
        try {
            getBrokerService(partition.getBroker())
                    .consumerRegisterC2B(createBrokerUnregisterRequest(partition,
                            isLastConsumed),
                            AddressUtils.getLocalAddress(), consumerConfig.isTlsEnable());
            logger.info(sBuffer.append("Unregister partition: consumer is ")
                    .append(consumerId).append(", partition=")
                    .append(partition.toString()).append(", isLastPackConsumed=")
                    .append(isLastConsumed).toString());
        } catch (Throwable e) {
            logger.error(sBuffer.append("Disconnect to Broker error! broker:")
                    .append(partition.getBroker().toString()).toString(), e);
            sBuffer.delete(0, sBuffer.length());
        }
    }
Start heartbeat thread threads.

@param result  process result
@param sBuffer  string buffer

@return  process result
inlong-tubemq/tubemq-client/src/main/java/org/apache/inlong/tubemq/client/consumer/SimpleClientBalanceConsumer.java