KsqlAuthorizationValidatorImpl¶

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

Creating Instance¶

KsqlAuthorizationValidatorImpl takes the following to be created:

• KsqlAccessValidator

KsqlAuthorizationValidatorImpl is created when:

• KsqlAuthorizationValidatorFactory is requested to create a KsqlAuthorizationValidator

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.

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.