@Test
public void testInvalidClusterResource() throws Exception {

  KafkaPrivilegeValidator kafkaPrivilegeValidator = new KafkaPrivilegeValidator();
  try {
    kafkaPrivilegeValidator.validate(new PrivilegeValidatorContext("host=host1->clluster=kafka-cluster->action=read"));
    Assert.fail("Expected ConfigurationException");
  } catch (ConfigurationException ex) {
  }
}