protected void operateStreamSources(String groupId, String streamId, String operator) {
        List<StreamSource> sources = streamSourceService.listSource(groupId, streamId);
        sources.forEach(source -> {
            operateStreamSource(source.genSourceRequest(), operator);
        });
    }
Operate stream sources, such as delete, stop, restart.
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/listener/source/AbstractSourceOperateListener.java