public void updCurConsumerInfo(ConsumerInfo inCsmInfo) {
        if (inCsmInfo.getConsumeType() != ConsumeType.CONSUME_CLIENT_REB) {
            return;
        }
        this.overTLS = inCsmInfo.overTLS;
        this.addrRcvFrom = inCsmInfo.addrRcvFrom;
        this.nodeId = inCsmInfo.getNodeId();
        updClientReportInfo(inCsmInfo.getCsmFromMaxOffsetCtrlId(),
                inCsmInfo.getLstAssignedTime(), inCsmInfo.getUsedTopicMetaInfoId());
    }
Initial Consumer node information

@param consumerId          the consumer id
@param overTLS             whether to communicate via TLS
@param group               the group name of the consumer
@param consumeType         the consume type
@param sourceCount         the minimum consumer count of consume group
@param nodeId              the node id
@param topicSet            the topic set subscribed
@param topicConditions     the topic filter condition set
@param curCsmCtrlId        the node's consume control id
@param syncInfo            the consumer report information
@param msgRcvFrom          the address received message
inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/nodemanage/nodeconsumer/ConsumerInfo.java