Merge pull request #11 from CloudKarafka/acl-bug

prefix User to principal
CloudKarafka · Aug 31, 2020 · 54a3c0d · 54a3c0d
2 parents a11d2f9 + 1572087
commit 54a3c0d
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/server/api/acl.go b/server/api/acl.go
@@ -129,11 +129,15 @@ func aclRequestFromHttpRequest(r *http.Request, checkKeys bool) (zookeeper.AclRe
 			}
 		}
 	}
+	principal := acl["principal"]
+	if !strings.HasPrefix(principal, "User:") {
+		principal = fmt.Sprintf("User:%s", principal)
+	}
 	req := zookeeper.AclRequest{
 		ResourceType:   resource,
 		PatternType:    pattern,
 		Name:           acl["name"],
-		Principal:      acl["principal"],
+		Principal:      principal,
 		Permission:     strings.ToUpper(acl["permission"]),
 		PermissionType: strings.ToUpper(acl["permission_type"]),
 		Host:           acl["host"],