in common/src/main/java/org/apache/rocketmq/schema/registry/common/auth/DefaultAccessControlServiceImpl.java [50:60]
private void checkPermission(
final Map<QualifiedName, Set<String>> accessACL,
final String userName,
final String name,
final SchemaOperation operation
) {
final Set<String> users = null;
if ((users != null) && !users.isEmpty() && !users.contains(userName)) {
throw new SchemaAuthorizedException(String.format("%s is not permitted for %s %s", userName, operation.name(), name));
}
}