@Override
    public Class<? extends Task> taskClass() {
        return FileStreamSourceTask.class;
    }
@Test
    public void testTaskClass() {
        connector.start(sourceProperties);
        assertEquals(FileStreamSourceTask.class, connector.taskClass());
    }