public void setRequireBound(final String sessionKey,
            final int sourceCount,
            final boolean isSelectBig,
            final Map<String, Long> partOffsetMap) {
        this.requireBound = true;
        this.subscribedTime = System.currentTimeMillis();
        this.sessionKey = sessionKey;
        this.isSelectBig = isSelectBig;
        this.sourceCount = sourceCount;
        int count = 0;
        StringBuilder sBuilder = new StringBuilder(256);
        for (Map.Entry<String, Long> entry : partOffsetMap.entrySet()) {
            if (entry.getKey() != null && entry.getValue() != null) {
                this.assignedPartMap.put(entry.getKey().trim(), entry.getValue());
                if (count++ > 0) {
                    sBuilder.append(TokenConstants.ARRAY_SEP);
                }
                sBuilder.append(entry.getKey().trim()).append(TokenConstants.EQ).append(entry.getValue());
            }
        }
        this.requiredPartition = sBuilder.toString();
    }
Set Bound Consumption information

@param sessionKey     consume session key
@param sourceCount    the client count of consume group
@param isSelectBig    whether select a bigger data If there is reset conflict
@param partOffsetMap  the map of partitionKey and bootstrap offset
inlong-tubemq/tubemq-client/src/main/java/org/apache/inlong/tubemq/client/consumer/ClientSubInfo.java