@Test(expected = FailedFetchException.class)
public void topicDoesNotExist() throws Exception {

    KafkaUtils.fetchMessages(config, simpleConsumer, new Partition(Broker.fromString(broker.getBrokerConnectionString()), 0), 0);
}