@Test (expected = IllegalArgumentException.class )
public void assignInvalidTask() {

    GlobalPartitionInformation globalPartitionInformation = new GlobalPartitionInformation();
    KafkaUtils.calculatePartitionsForTask(globalPartitionInformation, 1, 1);
}