KsqlAccessValidator¶

KsqlAccessValidator is an abstraction of access validators to check subject and topic access.

Contract¶

checkSubjectAccess¶

void checkSubjectAccess(
  KsqlSecurityContext securityContext,
  String subjectName,
  AclOperation operation)

Used when:

• KsqlAuthorizationValidatorImpl is requested to checkSchemaAccess
• KsqlCacheAccessValidator is requested to internalSubjectAccessValidator

checkTopicAccess¶

void checkTopicAccess(
  KsqlSecurityContext securityContext,
  String topicName,
  AclOperation operation)

Used when:

• KsqlAuthorizationValidatorImpl is requested to checkTopicAccess
• KsqlCacheAccessValidator is requested to internalTopicAccessValidator

Implementations¶

• KsqlBackendAccessValidator
• KsqlCacheAccessValidator
• KsqlProvidedAccessValidator