From eb98879cc3c211a62eddf5eb589c6584fc1151b3 Mon Sep 17 00:00:00 2001 From: litiliu <38579068+litiliu@users.noreply.github.com> Date: Fri, 7 Aug 2026 14:25:50 +0800 Subject: [PATCH] [common] Add standard principal type constants --- .../java/org/apache/fluss/security/acl/FlussPrincipal.java | 6 +++++- .../auth/sasl/authenticator/SaslServerAuthenticator.java | 2 +- 2 files changed, 6 insertions(+), 2 deletions(-) diff --git a/fluss-common/src/main/java/org/apache/fluss/security/acl/FlussPrincipal.java b/fluss-common/src/main/java/org/apache/fluss/security/acl/FlussPrincipal.java index 7a60e9c7b6..5c9bf4379b 100644 --- a/fluss-common/src/main/java/org/apache/fluss/security/acl/FlussPrincipal.java +++ b/fluss-common/src/main/java/org/apache/fluss/security/acl/FlussPrincipal.java @@ -41,7 +41,11 @@ */ @PublicEvolving public class FlussPrincipal implements Principal { - public static final FlussPrincipal ANONYMOUS = new FlussPrincipal("ANONYMOUS", "User"); + public static final String USER_TYPE = "User"; + public static final String GROUP_TYPE = "Group"; + public static final String ROLE_TYPE = "Role"; + + public static final FlussPrincipal ANONYMOUS = new FlussPrincipal("ANONYMOUS", USER_TYPE); /** The wildcard principal, which represents all principals. */ public static final FlussPrincipal WILD_CARD_PRINCIPAL = new FlussPrincipal("*", "*"); diff --git a/fluss-common/src/main/java/org/apache/fluss/security/auth/sasl/authenticator/SaslServerAuthenticator.java b/fluss-common/src/main/java/org/apache/fluss/security/auth/sasl/authenticator/SaslServerAuthenticator.java index 48231932e9..d23a82754e 100644 --- a/fluss-common/src/main/java/org/apache/fluss/security/auth/sasl/authenticator/SaslServerAuthenticator.java +++ b/fluss-common/src/main/java/org/apache/fluss/security/auth/sasl/authenticator/SaslServerAuthenticator.java @@ -148,6 +148,6 @@ public boolean isCompleted() { @Override public FlussPrincipal createPrincipal() { - return new FlussPrincipal(saslServer.getAuthorizationID(), "User"); + return new FlussPrincipal(saslServer.getAuthorizationID(), FlussPrincipal.USER_TYPE); } }