@Test
public void testValidPrivileges() throws Exception {

  KafkaPrivilegeValidator kafkaPrivilegeValidator = new KafkaPrivilegeValidator();
  try {
    kafkaPrivilegeValidator.validate(new PrivilegeValidatorContext("host=host1->cluster=kafka-cluster->action=read"));
  } catch (ConfigurationException ex) {
    Assert.fail("Not expected ConfigurationException");
  }
  try {
    kafkaPrivilegeValidator.validate(new PrivilegeValidatorContext("host=host1->topic=t1->action=read"));
  } catch (ConfigurationException ex) {
    Assert.fail("Not expected ConfigurationException");
  }
  try {
    kafkaPrivilegeValidator.validate(new PrivilegeValidatorContext("host=host1->consumergroup=g1->action=read"));
  } catch (ConfigurationException ex) {
    Assert.fail("Not expected ConfigurationException");
  }
}