@Test
public void testPrivilegeWithMoreParts() {

  KafkaPrivilegeValidator kafkaPrivilegeValidator = new KafkaPrivilegeValidator();
  try {
    kafkaPrivilegeValidator.validate(new PrivilegeValidatorContext("host=host1->topic=t1->consumergroup=cg1->action=read"));
    Assert.fail("Kafka privilege can have one Host authorizable, at most one non Host authorizable and one action.");
  } catch (ConfigurationException ex) {
    Assert.assertEquals(KafkaPrivilegeValidator.KafkaPrivilegeHelpMsg, ex.getMessage());
  }
}