@Override
  public void checkSubjectAccess(
      final KsqlSecurityContext securityContext,
      final String subjectName,
      final AclOperation operation
  ) {
    authorizationProvider.checkPrivileges(
        securityContext,
        AuthObjectType.SUBJECT,
        subjectName,
        ImmutableList.of(operation)
    );
  }
@Test
    public void shouldCheckSubjectTopicPrivilegesOnProvidedAccessValidator() {
        // When
        accessValidator.checkSubjectAccess(securityContext, "subject1", AclOperation.READ);

        // Then
        verify(authorizationProvider, times(1))
            .checkPrivileges(
                securityContext,
                AuthObjectType.SUBJECT,
                "subject1",
                ImmutableList.of(AclOperation.READ));
    }