#8613 fix start faild when acl2.0 authentication enabled

apache · Aug 30, 2024 · 59d3bf4 · 59d3bf4
1 parent 720c87e
commit 59d3bf4
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/auth/src/main/java/org/apache/rocketmq/auth/authorization/factory/AuthorizationFactory.java b/auth/src/main/java/org/apache/rocketmq/auth/authorization/factory/AuthorizationFactory.java
@@ -105,7 +105,7 @@ public static AuthorizationEvaluator getEvaluator(AuthConfig config, Supplier<?>
     public static AuthorizationStrategy getStrategy(AuthConfig config, Supplier<?> metadataService) {
         try {
             Class<? extends AuthorizationStrategy> clazz = StatelessAuthorizationStrategy.class;
-            if (StringUtils.isNotBlank(config.getAuthenticationStrategy())) {
+            if (StringUtils.isNotBlank(config.getAuthorizationStrategy())) {
                 clazz = (Class<? extends AuthorizationStrategy>) Class.forName(config.getAuthorizationStrategy());
             }
             return clazz.getDeclaredConstructor(AuthConfig.class, Supplier.class).newInstance(config, metadataService);