connect/runtime/src/main/java/org/apache/kafka/connect/tools/MockSinkConnector.java [33:66]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    private MockConnector delegate = new MockConnector();

    @Override
    public void initialize(ConnectorContext ctx) {
        delegate.initialize(ctx);
    }

    @Override
    public void initialize(ConnectorContext ctx, List<Map<String, String>> taskConfigs) {
        delegate.initialize(ctx, taskConfigs);
    }

    @Override
    public void reconfigure(Map<String, String> props) {
        delegate.reconfigure(props);
    }

    @Override
    public Config validate(Map<String, String> connectorConfigs) {
        return delegate.validate(connectorConfigs);
    }

    @Override
    public String version() {
        return delegate.version();
    }

    @Override
    public void start(Map<String, String> props) {
        delegate.start(props);
    }

    @Override
    public Class<? extends Task> taskClass() {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



connect/runtime/src/main/java/org/apache/kafka/connect/tools/MockSourceConnector.java [33:66]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    private MockConnector delegate = new MockConnector();

    @Override
    public void initialize(ConnectorContext ctx) {
        delegate.initialize(ctx);
    }

    @Override
    public void initialize(ConnectorContext ctx, List<Map<String, String>> taskConfigs) {
        delegate.initialize(ctx, taskConfigs);
    }

    @Override
    public void reconfigure(Map<String, String> props) {
        delegate.reconfigure(props);
    }

    @Override
    public Config validate(Map<String, String> connectorConfigs) {
        return delegate.validate(connectorConfigs);
    }

    @Override
    public String version() {
        return delegate.version();
    }

    @Override
    public void start(Map<String, String> props) {
        delegate.start(props);
    }

    @Override
    public Class<? extends Task> taskClass() {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -