Skip to content

KsqlAuthorizationValidatorImpl

KsqlAuthorizationValidatorImpl is a KsqlAuthorizationValidator that uses KsqlAccessValidator for checkTopicAccess and checkSchemaAccess.

Creating Instance

KsqlAuthorizationValidatorImpl takes the following to be created:

KsqlAuthorizationValidatorImpl is created when:

KsqlAccessValidator

KsqlAuthorizationValidatorImpl is given a KsqlAccessValidator when created.

The KsqlAccessValidator is used to checkTopicAccess and checkSchemaAccess.

checkAuthorization

void checkAuthorization(
  KsqlSecurityContext securityContext,
  MetaStore metaStore,
  Statement statement)

checkAuthorization is part of the KsqlAuthorizationValidator abstraction.

Statement Handler
Query validateQuery
InsertInto validateInsertInto
CreateAsSelect validateCreateAsSelect
PrintTopic validatePrintTopic
CreateSource validateCreateSource

validateInsertInto

void validateInsertInto(
  KsqlSecurityContext securityContext,
  MetaStore metaStore,
  InsertInto insertInto)

validateInsertInto validates the query of the given InsertInto.

validateInsertInto checks WRITE access to the underlying topic of the target of the given InsertInto.