private void logCommitStreamSetObject(CommitStreamSetObjectRequestData req) {
        if (!log.isInfoEnabled()) {
            return;
        }
        StringBuilder sb = new StringBuilder();
        sb.append("[CommitStreamSetObject]: successfully commit stream set object, ");
        sb.append("streamSetObjectId=").append(req.objectId()).append(", nodeId=").append(req.nodeId());
        sb.append(", nodeEpoch=").append(req.nodeEpoch()).append(", compactedObjects=").append(req.compactedObjectIds());
        log.info(sb.toString());
    }
Check whether this node is valid to operate the stream related resources.
metadata/src/main/java/org/apache/kafka/controller/stream/StreamControlManager.java