@Test(expected = ConnectException.class)
public void testMissingTopic() throws InterruptedException {

    replay();
    config.remove(FileStreamSourceConnector.TOPIC_CONFIG);
    task.start(config);
}