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