@Override
    public Class<? extends Task> taskClass() {
        return VerifiableSinkTask.class;
    }
A connector primarily intended for system tests.
@see VerifiableSinkTask
connect/test-plugins/src/main/java/org/apache/kafka/connect/tools/VerifiableSinkConnector.java